Skip to content

Conversation

@phillipleblanc
Copy link

@phillipleblanc phillipleblanc commented Feb 26, 2025

Which issue does this PR close?

TBD

Rationale for this change

This enables another way to prune files that don't need to be read, similar to partitioning, but based on the metadata of the file itself. This can be used to efficiently find all data that are in files that have changed since I last did a query, for example: SELECT * FROM test WHERE last_modified > {last_check_time}.

What changes are included in this PR?

Adds a new option to the ListingOptions for specifying certain metadata properties. The metadata properties that are supported are location, size and last_modified. When those properties are included, then they are added to the table schema (similar to partition columns) and the value is filled in by looking at the ObjectMeta for the file.

Are these changes tested?

Yes, added tests to path_partition.rs.

Are there any user-facing changes?

@phillipleblanc phillipleblanc merged commit 0479dfd into spiceai-43 Mar 10, 2025
@phillipleblanc phillipleblanc deleted the phillip/250225-metadata-cols-listing branch March 10, 2025 16:17
phillipleblanc added a commit that referenced this pull request Apr 8, 2025
… ListingTableProvider (#74)

* Initial work on metadata columns

* Metadata filtering working

* Working on plumbing to file scan config

* wip

* All wired up

* Working!

* Use MetadataColumn enum

* Add integration tests for metadata selection + pushdown filtering

UPSTREAM NOTE: This PR was submitted upstream: apache#15181
phillipleblanc added a commit that referenced this pull request Apr 8, 2025
… ListingTableProvider (#74)

* Initial work on metadata columns

* Metadata filtering working

* Working on plumbing to file scan config

* wip

* All wired up

* Working!

* Use MetadataColumn enum

* Add integration tests for metadata selection + pushdown filtering

UPSTREAM NOTE: This PR was submitted upstream: apache#15181
phillipleblanc added a commit that referenced this pull request Apr 8, 2025
… ListingTableProvider (#74)

* Initial work on metadata columns

* Metadata filtering working

* Working on plumbing to file scan config

* wip

* All wired up

* Working!

* Use MetadataColumn enum

* Add integration tests for metadata selection + pushdown filtering

UPSTREAM NOTE: This PR was submitted upstream: apache#15181
phillipleblanc added a commit that referenced this pull request Apr 17, 2025
… ListingTableProvider (#74)

* Initial work on metadata columns

* Metadata filtering working

* Working on plumbing to file scan config

* wip

* All wired up

* Working!

* Use MetadataColumn enum

* Add integration tests for metadata selection + pushdown filtering

UPSTREAM NOTE: This PR was submitted upstream: apache#15181
phillipleblanc added a commit that referenced this pull request Apr 25, 2025
… ListingTableProvider (#74)

* Initial work on metadata columns

* Metadata filtering working

* Working on plumbing to file scan config

* wip

* All wired up

* Working!

* Use MetadataColumn enum

* Add integration tests for metadata selection + pushdown filtering

UPSTREAM NOTE: This PR was submitted upstream: apache#15181
phillipleblanc added a commit that referenced this pull request May 7, 2025
… ListingTableProvider (#74)

* Initial work on metadata columns

* Metadata filtering working

* Working on plumbing to file scan config

* wip

* All wired up

* Working!

* Use MetadataColumn enum

* Add integration tests for metadata selection + pushdown filtering

UPSTREAM NOTE: This PR was submitted upstream: apache#15181
sgrebnov pushed a commit that referenced this pull request May 22, 2025
… ListingTableProvider (#74)

* Initial work on metadata columns

* Metadata filtering working

* Working on plumbing to file scan config

* wip

* All wired up

* Working!

* Use MetadataColumn enum

* Add integration tests for metadata selection + pushdown filtering

UPSTREAM NOTE: This PR was submitted upstream: apache#15181

# Conflicts:
#	datafusion/core/src/datasource/listing/table.rs
#	datafusion/core/tests/sql/path_partition.rs
#	datafusion/datasource/src/file_scan_config.rs
#	datafusion/datasource/src/mod.rs
sgrebnov pushed a commit that referenced this pull request May 26, 2025
… ListingTableProvider (#74)

UPSTREAM NOTE: This PR was attempted to be upstreamed but was not accepted. Needs to be applied manually
apache#15181
kczimm pushed a commit that referenced this pull request Aug 19, 2025
… ListingTableProvider (#74)

UPSTREAM NOTE: This PR was attempted to be upstreamed but was not accepted. Needs to be applied manually
apache#15181
kczimm pushed a commit that referenced this pull request Aug 21, 2025
… ListingTableProvider (#74)

UPSTREAM NOTE: This PR was attempted to be upstreamed but was not accepted. Needs to be applied manually
apache#15181
kczimm pushed a commit that referenced this pull request Aug 21, 2025
… ListingTableProvider (#74)

UPSTREAM NOTE: This PR was attempted to be upstreamed but was not accepted. Needs to be applied manually
apache#15181
Jeadie pushed a commit that referenced this pull request Sep 9, 2025
… ListingTableProvider (#74)

UPSTREAM NOTE: This PR was attempted to be upstreamed but was not accepted. Needs to be applied manually
apache#15181
Jeadie pushed a commit that referenced this pull request Sep 12, 2025
… ListingTableProvider (#74)

UPSTREAM NOTE: This PR was attempted to be upstreamed but was not accepted. Needs to be applied manually
apache#15181
peasee pushed a commit that referenced this pull request Oct 27, 2025
… ListingTableProvider (#74)

UPSTREAM NOTE: This PR was attempted to be upstreamed but was not accepted. Needs to be applied manually
apache#15181
peasee added a commit that referenced this pull request Oct 27, 2025
* fix: Ensure only tables or aliases that exist are projected (#52)
fix: More dangling references (#54)

UPSTREAM NOTE: This PR was attempted to be upstreamed in apache#13405 - but it was not accepted due to the complexity it brought. Phillip needs to figure out what a good solution that solves our problem and can be upstreamed is.

* Support for metadata columns (`location`, `size`, `last_modified`)  in ListingTableProvider (#74)

UPSTREAM NOTE: This PR was attempted to be upstreamed but was not accepted. Needs to be applied manually
apache#15181

* Infer placeholder datatype for `Expr::InSubquery` (#80)

UPSTREAM NOTE: Upstream PR has been created but not merged yet. Should be available in DF49
apache#15980

* Infer placeholder datatype after `LIMIT` clause as `DataType::Int64` (#81)

UPSTREAM NOTE: Upstream PR has been created but not merged yet. Should be available in DF49
apache#15980

* Do not double alias Exprs

UPSTREAM NOTE: This was attempted to be fixed with
apache#15008 but was closed

This is the tracking issue on DataFusion:
apache#14895
Do not double alias Exprs

* Add prefix to location metadata column (#82)

UPSTREAM NOTE: This will not be upstreamed as is.

* Infer placeholder types for CASE expressions (#87)

UPSTREAM NOTE: This has not been submitted upstream yet.

* Expand `infer_placeholder_types` to infer all possible placeholder types based on their expression (#88)

UPSTREAM NOTE: This has not been submitted upstream yet.

* Fix `Expr::infer_placeholder_types` inference to not fail (#89)

UPSTREAM NOTE: This has not been submitted upstream yet.

* cherry-pick parquet patch (#94)

* Fix array types coercion: preserve child element nullability for list types (#96)

UPSTREAM NOTE: This was submitted upstream and should be available in DF50

apache#17306

* Expand `infer_placeholder_types` to infer all possible placeholder types based on their expression (#88)

UPSTREAM NOTE: This has not been submitted upstream yet.

* do not enforce type guarantees on all Expr traversed in infer_placeholder_types (#97)

* Use UDTF function args in `LogicalPlan::TableScan` name (#98)

* use UDTF function args in LogicalPlan::TableScan name

* update test snapshots

* Implement timestamp_cast_dtype for SqliteDialect (#99)

* Use text for sqlite timestamp

* Add test

* Custom timestamp format for DuckDB (#102)

* Revert "cherry-pick parquet patch (#94)"

This reverts commit d780cc2.

* Support ExprNamed arguments to Scalar UDFs (#104)

* support ExprNamed until 17379 ships

* add same exprnamed lifting to udtf

* resolve projection against `ListingTable` table_schema incl. partition columns (#106)

* fix: Ensure ListingTable partitions are pruned when filters are not used (#108)

* fix: Prune partitions when no filters are defined

* fix: Backport for DF49:

* review: Address comments

* FileScanConfig: Preserve schema metadata across serde boundary (#107)

* FileScanConfig: preserve schema metadata across serde boundary

* add test

* Merge conflict fixes

UPSTREAM NOTE: this should not be upstreamed. This contains conflict fixes from various cherry-picks and differences in v50.

* update arrow-rs fork

UPSTREAM NOTE: this should not be upstreamed

---------

Co-authored-by: Phillip LeBlanc <phillip@leblanc.tech>
Co-authored-by: Kevin Zimmerman <4733573+kczimm@users.noreply.github.com>
Co-authored-by: sgrebnov <sergei.grebnov@gmail.com>
Co-authored-by: jeadie <jack@spice.ai>
Co-authored-by: Jack Eadie <jack.eadie0@gmail.com>
Co-authored-by: Viktor Yershov <krinart@gmail.com>
Co-authored-by: Viktor Yershov <viktor@spice.ai>
Co-authored-by: David Stancu <david@spice.ai>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants