Package | Description |
---|---|
org.apache.paimon.flink.lookup | |
org.apache.paimon.privilege | |
org.apache.paimon.table | |
org.apache.paimon.table.system |
Modifier and Type | Class and Description |
---|---|
class |
LookupFileStoreTable
FileStoreTable for lookup table. |
Modifier and Type | Class and Description |
---|---|
class |
PrivilegedFileStoreTable
FileStoreTable with privilege checks. |
Modifier and Type | Interface and Description |
---|---|
interface |
FileStoreTable
An abstraction layer above
FileStore to provide reading and writing of InternalRow . |
Modifier and Type | Class and Description |
---|---|
class |
DelegatedFileStoreTable
Delegated
FileStoreTable . |
class |
FallbackReadFileStoreTable
A
FileStoreTable which mainly read from the current branch. |
Modifier and Type | Method and Description |
---|---|
DataTable |
DataTable.switchToBranch(String branchName)
Get
DataTable with branch identified by branchName . |
Modifier and Type | Class and Description |
---|---|
class |
AuditLogTable
A
Table for reading audit log of table. |
class |
CompactBucketsTable
A table to produce modified partitions and buckets (also including files in streaming mode) for
each snapshot.
|
class |
FileMonitorTable
A table to produce modified files for snapshots.
|
class |
ReadOptimizedTable
A
Table optimized for reading by avoiding merging files. |
Modifier and Type | Method and Description |
---|---|
DataTable |
FileMonitorTable.switchToBranch(String branchName) |
DataTable |
CompactBucketsTable.switchToBranch(String branchName) |
DataTable |
AuditLogTable.switchToBranch(String branchName) |
DataTable |
ReadOptimizedTable.switchToBranch(String branchName) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.