org.apache.paimon.table.source

Class DataTableBatchScan

java.lang.Object

org.apache.paimon.table.source.AbstractDataTableScan

org.apache.paimon.table.source.DataTableBatchScan

All Implemented Interfaces:

DataTableScan, InnerTableScan, TableScan

public class DataTableBatchScan
extends AbstractDataTableScan

TableScan implementation for batch planning.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.paimon.table.source.TableScan

TableScan.Plan

Field Summary

Fields inherited from class org.apache.paimon.table.source.AbstractDataTableScan

snapshotReader

Constructor Summary

Constructors

Constructor and Description
DataTableBatchScan(boolean pkTable, CoreOptions options, SnapshotReader snapshotReader, DefaultValueAssigner defaultValueAssigner)

Method Summary

Modifier and Type	Method and Description
List<PartitionEntry>	listPartitionEntries()
TableScan.Plan	plan() Plan splits, throws EndOfScanException if the scan is ended.
InnerTableScan	withFilter(Predicate predicate)
InnerTableScan	withLimit(int limit)
DataTableScan	withShard(int indexOfThisSubtask, int numberOfParallelSubtasks) Specify the shard to be read, and allocate sharded files to read records.

Methods inherited from class org.apache.paimon.table.source.AbstractDataTableScan

createStartingScanner, dropStats, options, withBucket, withBucketFilter, withLevelFilter, withMetricsRegistry, withPartitionFilter, withPartitionFilter

Methods inherited from class java.lang.Object

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

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

listPartitions

Constructor Detail

DataTableBatchScan

public DataTableBatchScan(boolean pkTable,
                          CoreOptions options,
                          SnapshotReader snapshotReader,
                          DefaultValueAssigner defaultValueAssigner)

Method Detail

withFilter

public InnerTableScan withFilter(Predicate predicate)

withLimit

public InnerTableScan withLimit(int limit)

plan

public TableScan.Plan plan()

Description copied from interface: TableScan

Plan splits, throws EndOfScanException if the scan is ended.

listPartitionEntries

public List<PartitionEntry> listPartitionEntries()

withShard

public DataTableScan withShard(int indexOfThisSubtask,
                               int numberOfParallelSubtasks)

Description copied from interface: DataTableScan

Specify the shard to be read, and allocate sharded files to read records.