Modifier and Type | Class and Description |
---|---|
class |
ActionBase
Abstract base of
Action for table. |
class |
CloneAction
The Latest Snapshot clone action for Flink.
|
class |
CompactAction
Table compact action for Flink.
|
class |
CompactDatabaseAction
Database compact action for Flink.
|
class |
CreateBranchAction
Create branch action for Flink.
|
class |
CreateTagAction
Create tag action for Flink.
|
class |
CreateTagFromTimestampAction
Create tag from timestamp action for Flink.
|
class |
CreateTagFromWatermarkAction
Create tag from watermark action for Flink.
|
class |
DeleteAction
Delete from table action for Flink.
|
class |
DeleteBranchAction
Delete branch action for Flink.
|
class |
DeleteTagAction
Delete tag action for Flink.
|
class |
DropPartitionAction
Table drop partition action for Flink.
|
class |
ExpirePartitionsAction
Expire partitions action for Flink.
|
class |
ExpireSnapshotsAction
Expire snapshots action for Flink.
|
class |
ExpireTagsAction
Expire tags action for Flink.
|
class |
FastForwardAction
Fast Forward action for Flink.
|
class |
MarkPartitionDoneAction
Table partition mark done action for Flink.
|
class |
MergeIntoAction
Flink action for 'MERGE INTO', which references the syntax as follows (we use 'upsert' semantics
instead of 'update'):
|
class |
MigrateDatabaseAction
Migrate from external all hive table in database to paimon table.
|
class |
MigrateFileAction
Migrate from external hive table to paimon table.
|
class |
MigrateTableAction
Migrate from external hive table to paimon table.
|
class |
RemoveOrphanFilesAction
Action to remove the orphan data files and metadata files.
|
class |
RenameTagAction
Rename Tag action for Flink.
|
class |
RepairAction
Repair action for Flink.
|
class |
ReplaceTagAction
Replace tag action for Flink.
|
class |
ResetConsumerAction
Reset consumer action for Flink.
|
class |
RewriteFileIndexAction
Rewrite-file-index action for Flink.
|
class |
RollbackToAction
Rollback to specific version action for Flink.
|
class |
RollbackToTimestampAction
Rollback to specific timestamp action for Flink.
|
class |
SortCompactAction
Compact with sort action.
|
class |
TableActionBase
Abstract base of
Action for table. |
Modifier and Type | Class and Description |
---|---|
class |
MessageQueueSyncTableActionBase
Base
Action for synchronizing one message queue topic into one Paimon table. |
class |
SyncDatabaseActionBase
Base
Action for synchronizing into one Paimon database. |
class |
SynchronizationActionBase
Base
Action for table/database synchronizing job. |
class |
SyncTableActionBase
Base
Action for synchronizing into one Paimon table. |
Modifier and Type | Method and Description |
---|---|
Optional<Action> |
SyncDatabaseActionFactoryBase.create(MultipleParameterToolAdapter params) |
Optional<Action> |
SynchronizationActionFactoryBase.create(MultipleParameterToolAdapter params) |
Optional<Action> |
SyncTableActionFactoryBase.create(MultipleParameterToolAdapter params) |
Modifier and Type | Class and Description |
---|---|
class |
KafkaSyncDatabaseAction
Synchronize database from Kafka.
|
class |
KafkaSyncTableAction
Synchronize table from Kafka.
|
Modifier and Type | Class and Description |
---|---|
class |
MongoDBSyncDatabaseAction
An action class responsible for synchronizing MongoDB databases with a target system.
|
class |
MongoDBSyncTableAction
Represents an action to synchronize a specific MongoDB table with a target system.
|
Modifier and Type | Class and Description |
---|---|
class |
MySqlSyncDatabaseAction
An
Action which synchronize the whole MySQL database into one Paimon database. |
class |
MySqlSyncTableAction
An
Action which synchronize one or multiple MySQL tables into one Paimon table. |
Modifier and Type | Class and Description |
---|---|
class |
PostgresSyncTableAction
An
Action which synchronize one or multiple PostgreSQL tables into one Paimon table. |
Modifier and Type | Class and Description |
---|---|
class |
PulsarSyncDatabaseAction
Synchronize database from Pulsar.
|
class |
PulsarSyncTableAction
Synchronize table from Pulsar.
|
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.