org.apache.paimon.table.source

Class AbstractDataTableScan

java.lang.Object

org.apache.paimon.table.source.AbstractDataTableScan

All Implemented Interfaces:

DataTableScan, InnerTableScan, TableScan

Direct Known Subclasses:

DataTableBatchScan, DataTableStreamScan

public abstract class AbstractDataTableScan
extends Object
implements DataTableScan

An abstraction layer above FileStoreScan to provide input split generation.

Nested Class Summary

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

TableScan.Plan

Field Summary

Fields

Modifier and Type	Field and Description
protected SnapshotReader	snapshotReader

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractDataTableScan(CoreOptions options, SnapshotReader snapshotReader)

Method Summary

Modifier and Type	Method and Description
protected StartingScanner	createStartingScanner(boolean isStreaming)
CoreOptions	options()
AbstractDataTableScan	withBucket(int bucket)
AbstractDataTableScan	withBucketFilter(Filter<Integer> bucketFilter)
AbstractDataTableScan	withLevelFilter(Filter<Integer> levelFilter)
AbstractDataTableScan	withMetricsRegistry(MetricRegistry metricsRegistry)
AbstractDataTableScan	withPartitionFilter(List<BinaryRow> partitions)
AbstractDataTableScan	withPartitionFilter(Map<String,String> partitionSpec)

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.DataTableScan

withShard

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

withFilter, withLimit

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

listPartitionEntries, listPartitions, plan

Field Detail

snapshotReader

protected final SnapshotReader snapshotReader

Constructor Detail

AbstractDataTableScan

protected AbstractDataTableScan(CoreOptions options,
                                SnapshotReader snapshotReader)

Method Detail

withBucket

@VisibleForTesting
public AbstractDataTableScan withBucket(int bucket)

withBucketFilter

public AbstractDataTableScan withBucketFilter(Filter<Integer> bucketFilter)

Specified by:

withBucketFilter in interface InnerTableScan

withPartitionFilter

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

Specified by:

withPartitionFilter in interface InnerTableScan

withPartitionFilter

public AbstractDataTableScan withPartitionFilter(List<BinaryRow> partitions)

Specified by:

withPartitionFilter in interface InnerTableScan

withLevelFilter

public AbstractDataTableScan withLevelFilter(Filter<Integer> levelFilter)

Specified by:

withLevelFilter in interface InnerTableScan

withMetricsRegistry

public AbstractDataTableScan withMetricsRegistry(MetricRegistry metricsRegistry)

Specified by:

withMetricsRegistry in interface InnerTableScan

options

public CoreOptions options()

createStartingScanner

protected StartingScanner createStartingScanner(boolean isStreaming)