Package | Description |
---|---|
org.apache.paimon.flink.lookup | |
org.apache.paimon.table | |
org.apache.paimon.table.source | |
org.apache.paimon.table.system |
Modifier and Type | Class and Description |
---|---|
class |
LookupDataTableScan
StreamTableScan implementation for lookup streaming
planning. |
Modifier and Type | Method and Description |
---|---|
InnerTableScan |
InnerTable.newScan() |
InnerTableScan |
KnownSplitsTable.newScan() |
Modifier and Type | Interface and Description |
---|---|
interface |
DataTableScan
Table scan for data table.
|
interface |
StreamDataTableScan
Streaming
InnerTableScan with StreamTableScan . |
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. |
class |
ReadOnceTableScan
An
InnerTableScan for reading only once, this is for batch scan. |
Modifier and Type | Method and Description |
---|---|
default InnerTableScan |
InnerTableScan.withBucketFilter(Filter<Integer> bucketFilter) |
InnerTableScan |
InnerTableScan.withFilter(Predicate predicate) |
InnerTableScan |
DataTableBatchScan.withFilter(Predicate predicate) |
default InnerTableScan |
InnerTableScan.withLevelFilter(Filter<Integer> levelFilter) |
default InnerTableScan |
InnerTableScan.withLimit(int limit) |
InnerTableScan |
DataTableBatchScan.withLimit(int limit) |
default InnerTableScan |
InnerTableScan.withMetricsRegistry(MetricRegistry metricRegistry) |
default InnerTableScan |
InnerTableScan.withPartitionFilter(List<BinaryRow> partitions) |
default InnerTableScan |
InnerTableScan.withPartitionFilter(Map<String,String> partitionSpec) |
Modifier and Type | Method and Description |
---|---|
InnerTableScan |
TableLineageTable.newScan() |
InnerTableScan |
FilesTable.newScan() |
InnerTableScan |
SchemasTable.newScan() |
InnerTableScan |
OptionsTable.newScan() |
InnerTableScan |
SnapshotsTable.newScan() |
InnerTableScan |
TagsTable.newScan() |
InnerTableScan |
CatalogOptionsTable.newScan() |
InnerTableScan |
ManifestsTable.newScan() |
InnerTableScan |
StatisticTable.newScan() |
InnerTableScan |
AllTableOptionsTable.newScan() |
InnerTableScan |
BucketsTable.newScan() |
InnerTableScan |
ConsumersTable.newScan() |
InnerTableScan |
BranchesTable.newScan() |
InnerTableScan |
PartitionsTable.newScan() |
InnerTableScan |
AggregationFieldsTable.newScan() |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.