org.apache.paimon.table.source

Interface DataTableScan

All Superinterfaces:

InnerTableScan, TableScan

All Known Subinterfaces:

StreamDataTableScan

All Known Implementing Classes:

AbstractDataTableScan, DataTableBatchScan, DataTableStreamScan, LookupDataTableScan

public interface DataTableScan
extends InnerTableScan

Table scan for data table.

Nested Class Summary

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

TableScan.Plan

Method Summary

Modifier and Type	Method and Description
DataTableScan	withShard(int indexOfThisSubtask, int numberOfParallelSubtasks) Specify the shard to be read, and allocate sharded files to read records.

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

withBucketFilter, withFilter, withLevelFilter, withLimit, withMetricsRegistry, withPartitionFilter, withPartitionFilter

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

listPartitionEntries, listPartitions, plan

Method Detail

withShard

DataTableScan withShard(int indexOfThisSubtask,
                        int numberOfParallelSubtasks)

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