Package org.apache.iceberg

Class BasePartitionStatisticsScan

java.lang.Object

org.apache.iceberg.BasePartitionStatisticsScan

All Implemented Interfaces:

PartitionStatisticsScan

public class BasePartitionStatisticsScan
extends Object
implements PartitionStatisticsScan

Constructor Summary

Constructors

Constructor	Description
BasePartitionStatisticsScan(Table table)

Method Summary

Modifier and Type	Method	Description
PartitionStatisticsScan	filter(Expression newFilter)	Create a new scan from the results of this, where partitions are filtered by the Expression.
PartitionStatisticsScan	project(Schema newSchema)	Create a new scan from this with the schema as its projection.
CloseableIterable<PartitionStatistics>	scan()	Scans a partition statistics file belonging to a particular snapshot
PartitionStatisticsScan	useSnapshot(long newSnapshotId)	Create a new scan from this scan's configuration that will use the given snapshot by ID.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BasePartitionStatisticsScan

public BasePartitionStatisticsScan(Table table)

Method Details

useSnapshot

public PartitionStatisticsScan useSnapshot(long newSnapshotId)

Description copied from interface: PartitionStatisticsScan

Create a new scan from this scan's configuration that will use the given snapshot by ID.

Specified by:

useSnapshot in interface PartitionStatisticsScan

Parameters:

newSnapshotId - a snapshot ID

Returns:

a new scan based on this with the given snapshot ID

filter

public PartitionStatisticsScan filter(Expression newFilter)

Description copied from interface: PartitionStatisticsScan

Create a new scan from the results of this, where partitions are filtered by the Expression.

Specified by:

filter in interface PartitionStatisticsScan

Parameters:

newFilter - a filter expression

Returns:

a new scan based on this with results filtered by the expression

project

public PartitionStatisticsScan project(Schema newSchema)

Description copied from interface: PartitionStatisticsScan

Create a new scan from this with the schema as its projection.

Specified by:

project in interface PartitionStatisticsScan

Parameters:

newSchema - a projection schema

Returns:

a new scan based on this with the given projection

scan

public CloseableIterable<PartitionStatistics> scan()

Description copied from interface: PartitionStatisticsScan

Scans a partition statistics file belonging to a particular snapshot

Specified by:

scan in interface PartitionStatisticsScan

Returns:

an Iterable of partition statistics