org.apache.paimon.table

Class FallbackReadFileStoreTable.FallbackReadScan

java.lang.Object

org.apache.paimon.table.FallbackReadFileStoreTable.FallbackReadScan

All Implemented Interfaces:

DataTableScan, InnerTableScan, TableScan

Enclosing class:

FallbackReadFileStoreTable

public static class FallbackReadFileStoreTable.FallbackReadScan
extends Object
implements DataTableScan

Scan implementation for FallbackReadFileStoreTable.

Nested Class Summary

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

TableScan.Plan

Constructor Summary

Constructors

Constructor and Description
FallbackReadScan(DataTableScan mainScan, DataTableScan fallbackScan)

Method Summary

Modifier and Type	Method and Description
InnerTableScan	dropStats()
List<PartitionEntry>	listPartitionEntries()
TableScan.Plan	plan() Plan splits, throws EndOfScanException if the scan is ended.
FallbackReadFileStoreTable.FallbackReadScan	withBucketFilter(Filter<Integer> bucketFilter)
FallbackReadFileStoreTable.FallbackReadScan	withFilter(Predicate predicate)
FallbackReadFileStoreTable.FallbackReadScan	withLevelFilter(Filter<Integer> levelFilter)
FallbackReadFileStoreTable.FallbackReadScan	withLimit(int limit)
FallbackReadFileStoreTable.FallbackReadScan	withMetricRegistry(MetricRegistry metricRegistry) Set MetricRegistry to table scan.
FallbackReadFileStoreTable.FallbackReadScan	withPartitionFilter(List<BinaryRow> partitions)
FallbackReadFileStoreTable.FallbackReadScan	withPartitionFilter(Map<String,String> partitionSpec)
InnerTableScan	withPartitionsFilter(List<Map<String,String>> partitions)
FallbackReadFileStoreTable.FallbackReadScan	withShard(int indexOfThisSubtask, int numberOfParallelSubtasks) Specify the shard to be read, and allocate sharded files to read records.

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

withBucket, withReadType

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

listPartitions

Constructor Detail

FallbackReadScan

public FallbackReadScan(DataTableScan mainScan,
                        DataTableScan fallbackScan)

Method Detail

withShard

public FallbackReadFileStoreTable.FallbackReadScan withShard(int indexOfThisSubtask,
                                                             int numberOfParallelSubtasks)

Description copied from interface: DataTableScan

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

Specified by:

withShard in interface DataTableScan

withFilter

public FallbackReadFileStoreTable.FallbackReadScan withFilter(Predicate predicate)

Specified by:

withFilter in interface InnerTableScan

withLimit

public FallbackReadFileStoreTable.FallbackReadScan withLimit(int limit)

Specified by:

withLimit in interface InnerTableScan

withPartitionFilter

public FallbackReadFileStoreTable.FallbackReadScan withPartitionFilter(Map<String,String> partitionSpec)

Specified by:

withPartitionFilter in interface InnerTableScan

withPartitionFilter

public FallbackReadFileStoreTable.FallbackReadScan withPartitionFilter(List<BinaryRow> partitions)

Specified by:

withPartitionFilter in interface InnerTableScan

withPartitionsFilter

public InnerTableScan withPartitionsFilter(List<Map<String,String>> partitions)

Specified by:

withPartitionsFilter in interface InnerTableScan

withBucketFilter

public FallbackReadFileStoreTable.FallbackReadScan withBucketFilter(Filter<Integer> bucketFilter)

Specified by:

withBucketFilter in interface InnerTableScan

withLevelFilter

public FallbackReadFileStoreTable.FallbackReadScan withLevelFilter(Filter<Integer> levelFilter)

Specified by:

withLevelFilter in interface InnerTableScan

withMetricRegistry

public FallbackReadFileStoreTable.FallbackReadScan withMetricRegistry(MetricRegistry metricRegistry)

Description copied from interface: TableScan

Set MetricRegistry to table scan.

Specified by:

withMetricRegistry in interface InnerTableScan

Specified by:

withMetricRegistry in interface TableScan

dropStats

public InnerTableScan dropStats()

Specified by:

dropStats in interface InnerTableScan

plan

public TableScan.Plan plan()

Description copied from interface: TableScan

Plan splits, throws EndOfScanException if the scan is ended.

Specified by:

plan in interface TableScan

listPartitionEntries

public List<PartitionEntry> listPartitionEntries()

Specified by:

listPartitionEntries in interface TableScan