org.apache.paimon.table.source

Class ReadBuilderImpl

java.lang.Object

org.apache.paimon.table.source.ReadBuilderImpl

All Implemented Interfaces:

Serializable, ReadBuilder

public class ReadBuilderImpl
extends Object
implements ReadBuilder

Implementation for ReadBuilder.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ReadBuilderImpl(InnerTable table)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
int	hashCode()
TableRead	newRead() Create a TableRead to read Splits.
TableScan	newScan() Create a TableScan to perform batch planning.
StreamTableScan	newStreamScan() Create a TableScan to perform streaming planning.
RowType	readType() Returns read row type, projected by ReadBuilder.withProjection(int[]).
String	tableName() A name to identify the table.
ReadBuilder	withBucketFilter(Filter<Integer> bucketFilter) Push bucket filter.
ReadBuilder	withFilter(Predicate filter) Push filters, will filter the data as much as possible, but it is not guaranteed that it is a complete filter.
ReadBuilder	withLimit(int limit) the row number pushed down.
ReadBuilder	withPartitionFilter(Map<String,String> partitionSpec) Push partition filter.
ReadBuilder	withProjection(int[][] projection) Push nested projection.
ReadBuilder	withShard(int indexOfThisSubtask, int numberOfParallelSubtasks) Specify the shard to be read, and allocate sharded files to read records.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.paimon.table.source.ReadBuilder

withFilter, withProjection

Constructor Detail

ReadBuilderImpl

public ReadBuilderImpl(InnerTable table)

Method Detail

tableName

public String tableName()

Description copied from interface: ReadBuilder

A name to identify the table.

Specified by:

tableName in interface ReadBuilder

readType

public RowType readType()

Description copied from interface: ReadBuilder

Returns read row type, projected by ReadBuilder.withProjection(int[]).

Specified by:

readType in interface ReadBuilder

withFilter

public ReadBuilder withFilter(Predicate filter)

Description copied from interface: ReadBuilder

Push filters, will filter the data as much as possible, but it is not guaranteed that it is a complete filter.

Specified by:

withFilter in interface ReadBuilder

withPartitionFilter

public ReadBuilder withPartitionFilter(Map<String,String> partitionSpec)

Description copied from interface: ReadBuilder

Push partition filter.

Specified by:

withPartitionFilter in interface ReadBuilder

withProjection

public ReadBuilder withProjection(int[][] projection)

Description copied from interface: ReadBuilder

Push nested projection. For example, [[0, 2, 1], ...] specifies to include the 2nd field of the 3rd field of the 1st field in the top-level row.

Specified by:

withProjection in interface ReadBuilder

withLimit

public ReadBuilder withLimit(int limit)

Description copied from interface: ReadBuilder

the row number pushed down.

Specified by:

withLimit in interface ReadBuilder

withShard

public ReadBuilder withShard(int indexOfThisSubtask,
                             int numberOfParallelSubtasks)

Description copied from interface: ReadBuilder

Specify the shard to be read, and allocate sharded files to read records. Note that this method cannot be used simultaneously with ReadBuilder.withBucketFilter(Filter).

Reason: Sharding and bucket filtering are different logical mechanisms for selecting subsets of table data. Applying both methods simultaneously introduces conflicting selection criteria.

Specified by:

withShard in interface ReadBuilder

withBucketFilter

public ReadBuilder withBucketFilter(Filter<Integer> bucketFilter)

Description copied from interface: ReadBuilder

Push bucket filter. Note that this method cannot be used simultaneously with ReadBuilder.withShard(int, int).

Reason: Bucket filtering and sharding are different logical mechanisms for selecting subsets of table data. Applying both methods simultaneously introduces conflicting selection criteria.

Specified by:

withBucketFilter in interface ReadBuilder

newScan

public TableScan newScan()

Description copied from interface: ReadBuilder

Create a TableScan to perform batch planning.

Specified by:

newScan in interface ReadBuilder

newStreamScan

public StreamTableScan newStreamScan()

Description copied from interface: ReadBuilder

Create a TableScan to perform streaming planning.

Specified by:

newStreamScan in interface ReadBuilder

newRead

public TableRead newRead()

Description copied from interface: ReadBuilder

Create a TableRead to read Splits.

Specified by:

newRead in interface ReadBuilder

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object