Package | Description |
---|---|
org.apache.paimon.flink.lookup | |
org.apache.paimon.privilege | |
org.apache.paimon.table | |
org.apache.paimon.table.source | |
org.apache.paimon.table.system |
Modifier and Type | Class and Description |
---|---|
class |
LookupCompactDiffRead
An
InnerTableRead that reads the data changed before and after compaction. |
Modifier and Type | Method and Description |
---|---|
InnerTableRead |
LookupCompactDiffRead.forceKeepDelete() |
protected InnerTableRead |
LookupCompactDiffRead.innerWithFilter(Predicate predicate) |
InnerTableRead |
LookupFileStoreTable.newRead() |
Modifier and Type | Method and Description |
---|---|
InnerTableRead |
PrivilegedFileStoreTable.newRead() |
Modifier and Type | Method and Description |
---|---|
InnerTableRead |
InnerTable.newRead() |
InnerTableRead |
KnownSplitsTable.newRead() |
InnerTableRead |
DelegatedFileStoreTable.newRead() |
InnerTableRead |
FallbackReadFileStoreTable.newRead() |
Modifier and Type | Class and Description |
---|---|
class |
AbstractDataTableRead<T>
A
InnerTableRead for data table. |
class |
KeyValueTableRead
An abstraction layer above
MergeFileSplitRead to provide reading of InternalRow . |
Modifier and Type | Method and Description |
---|---|
InnerTableRead |
KeyValueTableRead.forceKeepDelete() |
default InnerTableRead |
InnerTableRead.forceKeepDelete() |
protected InnerTableRead |
KeyValueTableRead.innerWithFilter(Predicate predicate) |
protected abstract InnerTableRead |
AbstractDataTableRead.innerWithFilter(Predicate predicate) |
default InnerTableRead |
InnerTableRead.withFilter(List<Predicate> predicates) |
InnerTableRead |
AbstractDataTableRead.withFilter(Predicate predicate) |
InnerTableRead |
InnerTableRead.withFilter(Predicate predicate) |
InnerTableRead |
AbstractDataTableRead.withProjection(int[] projection) |
default InnerTableRead |
InnerTableRead.withProjection(int[] projection)
Deprecated.
|
InnerTableRead |
AbstractDataTableRead.withReadType(RowType readType) |
default InnerTableRead |
InnerTableRead.withReadType(RowType readType) |
Modifier and Type | Class and Description |
---|---|
protected static class |
TableLineageTable.TableLineageRead
Table lineage read with lineage meta query.
|
Modifier and Type | Method and Description |
---|---|
InnerTableRead |
FileMonitorTable.newRead() |
InnerTableRead |
FilesTable.newRead() |
InnerTableRead |
SchemasTable.newRead() |
InnerTableRead |
CompactBucketsTable.newRead() |
InnerTableRead |
OptionsTable.newRead() |
InnerTableRead |
SnapshotsTable.newRead() |
InnerTableRead |
TagsTable.newRead() |
InnerTableRead |
CatalogOptionsTable.newRead() |
InnerTableRead |
ManifestsTable.newRead() |
InnerTableRead |
AuditLogTable.newRead() |
InnerTableRead |
StatisticTable.newRead() |
InnerTableRead |
AllTableOptionsTable.newRead() |
InnerTableRead |
SinkTableLineageTable.newRead() |
InnerTableRead |
ReadOptimizedTable.newRead() |
InnerTableRead |
BucketsTable.newRead() |
InnerTableRead |
ConsumersTable.newRead() |
InnerTableRead |
BranchesTable.newRead() |
InnerTableRead |
SourceTableLineageTable.newRead() |
InnerTableRead |
PartitionsTable.newRead() |
InnerTableRead |
AggregationFieldsTable.newRead() |
InnerTableRead |
TableLineageTable.TableLineageRead.withFilter(Predicate predicate) |
InnerTableRead |
TableLineageTable.TableLineageRead.withReadType(RowType readType) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.