org.apache.iceberg

Class FindFiles.Builder

java.lang.Object

org.apache.iceberg.FindFiles.Builder

Enclosing class:

FindFiles

public static class FindFiles.Builder
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
Builder(Table table)

Method Summary

Modifier and Type	Method and Description
FindFiles.Builder	asOfTime(long timestampMillis) Base results on files in the snapshot that was current as of a timestamp.
FindFiles.Builder	caseInsensitive()
FindFiles.Builder	caseSensitive(boolean findCaseSensitive)
CloseableIterable<DataFile>	collect() Returns all files in the table that match all of the filters.
FindFiles.Builder	inPartition(PartitionSpec spec, StructLike partition) Filter results to files in any one of the given partitions.
FindFiles.Builder	inPartitions(PartitionSpec spec, java.util.List<StructLike> partitions) Filter results to files in any one of the given partitions.
FindFiles.Builder	inPartitions(PartitionSpec spec, StructLike... partitions) Filter results to files in any one of the given partitions.
FindFiles.Builder	inSnapshot(long findSnapshotId) Base results on the given snapshot.
FindFiles.Builder	withMetadataMatching(Expression expr) Filter results using a metadata filter for the data in a DataFile.
FindFiles.Builder	withRecordsMatching(Expression expr) Filter results using a record filter.

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder(Table table)

Method Detail

caseInsensitive

public FindFiles.Builder caseInsensitive()

caseSensitive

public FindFiles.Builder caseSensitive(boolean findCaseSensitive)

inSnapshot

public FindFiles.Builder inSnapshot(long findSnapshotId)

Base results on the given snapshot.

Parameters:

findSnapshotId - a snapshot ID

Returns:

this for method chaining

asOfTime

public FindFiles.Builder asOfTime(long timestampMillis)

Base results on files in the snapshot that was current as of a timestamp.

Parameters:

timestampMillis - a timestamp in milliseconds

Returns:

this for method chaining

withRecordsMatching

public FindFiles.Builder withRecordsMatching(Expression expr)

Filter results using a record filter. Files that may contain at least one matching record will be returned by collect().

Parameters:

expr - a record filter

Returns:

this for method chaining

withMetadataMatching

public FindFiles.Builder withMetadataMatching(Expression expr)

Filter results using a metadata filter for the data in a DataFile.

Parameters:

expr - a filter for DataFile metadata columns

Returns:

this for method chaining

inPartition

public FindFiles.Builder inPartition(PartitionSpec spec,
                                     StructLike partition)

Filter results to files in any one of the given partitions.

Parameters:

spec - a spec for the partitions

partition - a StructLike that stores a partition tuple

Returns:

this for method chaining

inPartitions

public FindFiles.Builder inPartitions(PartitionSpec spec,
                                      StructLike... partitions)

Filter results to files in any one of the given partitions.

Parameters:

spec - a spec for the partitions

partitions - one or more StructLike that stores a partition tuple

Returns:

this for method chaining

inPartitions

public FindFiles.Builder inPartitions(PartitionSpec spec,
                                      java.util.List<StructLike> partitions)

Filter results to files in any one of the given partitions.

Parameters:

spec - a spec for the partitions

partitions - a list of StructLike that stores a partition tuple

Returns:

this for method chaining

collect

public CloseableIterable<DataFile> collect()

Returns all files in the table that match all of the filters.