Package org.apache.iceberg
Interface PartitionStatisticsScan
- All Known Implementing Classes:
BasePartitionStatisticsScan
public interface PartitionStatisticsScan
API for configuring partition statistics scan.
-
Method Summary
Modifier and TypeMethodDescriptionfilter(Expression filter) Create a new scan from the results of this, where partitions are filtered by theExpression.Create a new scan from this with the schema as its projection.scan()Scans a partition statistics file belonging to a particular snapshotuseSnapshot(long snapshotId) Create a new scan from this scan's configuration that will use the given snapshot by ID.
-
Method Details
-
useSnapshot
Create a new scan from this scan's configuration that will use the given snapshot by ID.- Parameters:
snapshotId- a snapshot ID- Returns:
- a new scan based on this with the given snapshot ID
- Throws:
IllegalArgumentException- if the snapshot cannot be found
-
filter
Create a new scan from the results of this, where partitions are filtered by theExpression.- Parameters:
filter- a filter expression- Returns:
- a new scan based on this with results filtered by the expression
-
project
Create a new scan from this with the schema as its projection.- Parameters:
schema- a projection schema- Returns:
- a new scan based on this with the given projection
-
scan
CloseableIterable<PartitionStatistics> scan()Scans a partition statistics file belonging to a particular snapshot- Returns:
- an Iterable of partition statistics
-