Package | Description |
---|---|
org.apache.paimon.flink.sink.cdc | |
org.apache.paimon.stats | |
org.apache.paimon.table | |
org.apache.paimon.table.sink | |
org.apache.paimon.table.system |
Modifier and Type | Class and Description |
---|---|
class |
CdcRecord
A data change message from the CDC source.
|
class |
CdcSinkBuilder<T>
Builder for sink when syncing records into one Paimon table.
|
interface |
EventParser<T>
|
class |
RichCdcRecord
A change message contains schema and data.
|
Modifier and Type | Class and Description |
---|---|
class |
ColStats<T>
Col stats, supports the following stats.
|
class |
Statistics
Global stats, supports the following stats.
|
Modifier and Type | Class and Description |
---|---|
class |
BucketMode
Bucket mode of the table, it affects the writing process and also affects the bucket skipping in
reading.
|
Modifier and Type | Method and Description |
---|---|
void |
Table.createBranch(String branchName)
Create an empty branch.
|
void |
Table.createBranch(String branchName,
String tagName)
Create a branch from given tag.
|
void |
Table.createTag(String tagName)
Create a tag from latest snapshot.
|
void |
Table.createTag(String tagName,
java.time.Duration timeRetained) |
void |
Table.createTag(String tagName,
long fromSnapshotId)
Create a tag from given snapshot.
|
void |
Table.createTag(String tagName,
long fromSnapshotId,
java.time.Duration timeRetained) |
void |
Table.deleteBranch(String branchName)
Delete a branch by branchName.
|
default void |
Table.deleteBranches(String branchNames)
Delete branches, branches are separated by commas.
|
void |
Table.deleteTag(String tagName)
Delete a tag by name.
|
default void |
Table.deleteTags(String tagStr)
Delete tags, tags are separated by commas.
|
void |
Table.fastForward(String branchName)
Merge a branch to main branch.
|
SimpleFileReader<IndexManifestEntry> |
Table.indexManifestFileReader()
Reader to read index manifest entry from index manifest file.
|
OptionalLong |
Table.latestSnapshotId()
Get the latest snapshot id for this table, or empty if there are no snapshots.
|
SimpleFileReader<ManifestEntry> |
Table.manifestFileReader()
Reader to read manifest entry from manifest file.
|
SimpleFileReader<ManifestFileMeta> |
Table.manifestListReader()
Reader to read manifest file meta from manifest list file.
|
ExpireSnapshots |
Table.newExpireChangelog() |
ExpireSnapshots |
Table.newExpireSnapshots()
Manually expire snapshots, parameters can be controlled independently of table options.
|
void |
Table.renameTag(String tagName,
String targetTagName) |
void |
Table.replaceTag(String tagName,
Long fromSnapshotId,
java.time.Duration timeRetained)
Replace a tag with new snapshot id and new time retained.
|
void |
Table.rollbackTo(long snapshotId)
Rollback table's state to a specific snapshot.
|
void |
Table.rollbackTo(String tagName)
Rollback table's state to a specific tag.
|
Snapshot |
Table.snapshot(long snapshotId)
Get the
Snapshot from snapshot id. |
Optional<Statistics> |
Table.statistics()
Optional statistics of this table.
|
Modifier and Type | Method and Description |
---|---|
Optional<WriteSelector> |
WriteBuilder.newWriteSelector()
Create a
WriteSelector to partition records before writers. |
Modifier and Type | Class and Description |
---|---|
class |
FileMonitorTable
A table to produce modified files for snapshots.
|
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.