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

Packages that use DataTableScan

Package	Description
org.apache.paimon.privilege
org.apache.paimon.table
org.apache.paimon.table.source
org.apache.paimon.table.system

Uses of DataTableScan in org.apache.paimon.privilege

Methods in org.apache.paimon.privilege that return DataTableScan

Modifier and Type	Method and Description
DataTableScan	PrivilegedFileStoreTable.newScan()

Uses of DataTableScan in org.apache.paimon.table

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

Modifier and Type	Method and Description
DataTableScan	DataTable.newScan()
DataTableScan	DelegatedFileStoreTable.newScan()
DataTableScan	FallbackReadFileStoreTable.newScan()

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

Subinterfaces of DataTableScan in org.apache.paimon.table.source

Modifier and Type	Interface and Description
interface	StreamDataTableScan Streaming InnerTableScan with StreamTableScan.

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

Modifier and Type	Class and Description
class	AbstractDataTableScan An abstraction layer above FileStoreScan to provide input split generation.
class	DataTableBatchScan TableScan implementation for batch planning.
class	DataTableStreamScan StreamTableScan implementation for streaming planning.

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

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

Uses of DataTableScan in org.apache.paimon.table.system

Methods in org.apache.paimon.table.system that return DataTableScan

Modifier and Type	Method and Description
DataTableScan	FileMonitorTable.newScan()
DataTableScan	CompactBucketsTable.newScan()
DataTableScan	AuditLogTable.newScan()