Uses of Interface
org.apache.paimon.table.source.ReadBuilder

Packages that use ReadBuilder

Package	Description
org.apache.paimon.flink.source
org.apache.paimon.flink.source.align
org.apache.paimon.flink.source.operator
org.apache.paimon.hive.mapred
org.apache.paimon.table
org.apache.paimon.table.source

Uses of ReadBuilder in org.apache.paimon.flink.source

Fields in org.apache.paimon.flink.source declared as ReadBuilder

Modifier and Type	Field and Description
protected ReadBuilder	FlinkSource.readBuilder

Constructors in org.apache.paimon.flink.source with parameters of type ReadBuilder

Constructor and Description
ContinuousFileStoreSource(ReadBuilder readBuilder, Map<String,String> options, Long limit)
ContinuousFileStoreSource(ReadBuilder readBuilder, Map<String,String> options, Long limit, BucketMode bucketMode)
FlinkSource(ReadBuilder readBuilder, Long limit)
StaticFileStoreSource(ReadBuilder readBuilder, Long limit, int splitBatchSize, FlinkConnectorOptions.SplitAssignMode splitAssignMode)
StaticFileStoreSource(ReadBuilder readBuilder, Long limit, int splitBatchSize, FlinkConnectorOptions.SplitAssignMode splitAssignMode, DynamicPartitionFilteringInfo dynamicPartitionFilteringInfo)

Uses of ReadBuilder in org.apache.paimon.flink.source.align

Constructors in org.apache.paimon.flink.source.align with parameters of type ReadBuilder

Constructor and Description
AlignedContinuousFileStoreSource(ReadBuilder readBuilder, Map<String,String> options, Long limit, BucketMode bucketMode)

Uses of ReadBuilder in org.apache.paimon.flink.source.operator

Methods in org.apache.paimon.flink.source.operator with parameters of type ReadBuilder

Modifier and Type	Method and Description
static org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData>	MonitorFunction.buildSource(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, String name, org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> typeInfo, ReadBuilder readBuilder, long monitorInterval, boolean emitSnapshotWatermark, boolean shuffleBucketWithPartition, BucketMode bucketMode)

Constructors in org.apache.paimon.flink.source.operator with parameters of type ReadBuilder

Constructor and Description
MonitorFunction(ReadBuilder readBuilder, long monitorInterval, boolean emitSnapshotWatermark)
ReadOperator(ReadBuilder readBuilder)

Uses of ReadBuilder in org.apache.paimon.hive.mapred

Constructors in org.apache.paimon.hive.mapred with parameters of type ReadBuilder

Constructor and Description
PaimonRecordReader(ReadBuilder readBuilder, PaimonInputSplit split, List<String> paimonColumns, List<String> hiveColumns, List<String> selectedColumns, String tagToPartField)

Uses of ReadBuilder in org.apache.paimon.table

Methods in org.apache.paimon.table that return ReadBuilder

Modifier and Type	Method and Description
ReadBuilder	Table.newReadBuilder() Returns a new read builder.
default ReadBuilder	FormatTable.newReadBuilder()
default ReadBuilder	InnerTable.newReadBuilder()

Uses of ReadBuilder in org.apache.paimon.table.source

Classes in org.apache.paimon.table.source that implement ReadBuilder

Modifier and Type	Class and Description
class	ReadBuilderImpl Implementation for ReadBuilder.

Methods in org.apache.paimon.table.source that return ReadBuilder

Modifier and Type	Method and Description
ReadBuilder	ReadBuilderImpl.dropStats()
ReadBuilder	ReadBuilder.dropStats() Delete stats in scan plan result.
ReadBuilder	ReadBuilderImpl.withBucketFilter(Filter<Integer> bucketFilter)
ReadBuilder	ReadBuilder.withBucketFilter(Filter<Integer> bucketFilter) Push bucket filter.
default ReadBuilder	ReadBuilder.withFilter(List<Predicate> predicates) Apply filters to the readers to decrease the number of produced records.
ReadBuilder	ReadBuilderImpl.withFilter(Predicate filter)
ReadBuilder	ReadBuilder.withFilter(Predicate predicate) Push filters, will filter the data as much as possible, but it is not guaranteed that it is a complete filter.
ReadBuilder	ReadBuilderImpl.withLimit(int limit)
ReadBuilder	ReadBuilder.withLimit(int limit) the row number pushed down.
ReadBuilder	ReadBuilderImpl.withPartitionFilter(Map<String,String> partitionSpec)
ReadBuilder	ReadBuilder.withPartitionFilter(Map<String,String> partitionSpec) Push partition filter.
ReadBuilder	ReadBuilderImpl.withProjection(int[] projection)
ReadBuilder	ReadBuilder.withProjection(int[] projection) Apply projection to the reader, if you need nested row pruning, use withReadType(RowType) instead.
default ReadBuilder	ReadBuilder.withProjection(int[][] projection) Deprecated.
ReadBuilder	ReadBuilderImpl.withReadType(RowType readType)
ReadBuilder	ReadBuilder.withReadType(RowType readType) Push read row type to the reader, support nested row pruning.
ReadBuilder	ReadBuilderImpl.withShard(int indexOfThisSubtask, int numberOfParallelSubtasks)
ReadBuilder	ReadBuilder.withShard(int indexOfThisSubtask, int numberOfParallelSubtasks) Specify the shard to be read, and allocate sharded files to read records.