Modifier and Type | Interface and Description |
---|---|
interface |
CatalogFactory
Factory to create
Catalog . |
interface |
CatalogLockFactory
Factory to create
CatalogLock . |
Modifier and Type | Class and Description |
---|---|
class |
FileSystemCatalogFactory
Factory to create
FileSystemCatalog . |
Modifier and Type | Method and Description |
---|---|
static <T extends Factory> |
FactoryUtil.discoverFactory(ClassLoader classLoader,
Class<T> factoryClass,
String identifier)
Discovers a factory using the given factory base class and identifier.
|
static <T extends Factory> |
FactoryUtil.discoverIdentifiers(ClassLoader classLoader,
Class<T> factoryClass) |
Modifier and Type | Interface and Description |
---|---|
interface |
ActionFactory
Factory to create
Action . |
Modifier and Type | Class and Description |
---|---|
class |
SyncDatabaseActionFactoryBase<T extends SyncDatabaseActionBase>
Base
ActionFactory for synchronizing into database. |
class |
SynchronizationActionFactoryBase<T extends SynchronizationActionBase>
Base
ActionFactory for table/database synchronizing job. |
class |
SyncTableActionFactoryBase
Base
ActionFactory for synchronizing into one Paimon table. |
Modifier and Type | Interface and Description |
---|---|
interface |
DataFormatFactory
Factory to create
DataFormat . |
Modifier and Type | Class and Description |
---|---|
class |
AliyunDataFormatFactory
Factory to create
AliyunDataFormat . |
Modifier and Type | Class and Description |
---|---|
class |
CanalDataFormatFactory
Factory to create
CanalDataFormat . |
Modifier and Type | Class and Description |
---|---|
class |
DebeziumAvroDataFormatFactory
Factory to create
DebeziumAvroDataFormat . |
class |
DebeziumJsonDataFormatFactory
Factory to create
DebeziumJsonDataFormat . |
Modifier and Type | Class and Description |
---|---|
class |
DMSDataFormatFactory
Factory to create
DMSDataFormat . |
Modifier and Type | Class and Description |
---|---|
class |
JsonDataFormatFactory
Factory to create
JsonDataFormat . |
Modifier and Type | Class and Description |
---|---|
class |
MaxwellDataFormatFactory
Factory to create
MaxwellDataFormat . |
Modifier and Type | Class and Description |
---|---|
class |
OggDataFormatFactory
Factory to create
OggDataFormat . |
Modifier and Type | Class and Description |
---|---|
class |
KafkaSyncDatabaseActionFactory
Factory to create
KafkaSyncDatabaseAction . |
class |
KafkaSyncTableActionFactory
Factory to create
KafkaSyncTableAction . |
Modifier and Type | Class and Description |
---|---|
class |
MongoDBSyncDatabaseActionFactory
Factory to create
MongoDBSyncDatabaseAction . |
class |
MongoDBSyncTableActionFactory
Factory to create
MongoDBSyncTableAction . |
Modifier and Type | Class and Description |
---|---|
class |
MySqlSyncDatabaseActionFactory
Factory to create
MySqlSyncDatabaseAction . |
class |
MySqlSyncTableActionFactory
Factory to create
MySqlSyncTableAction . |
Modifier and Type | Class and Description |
---|---|
class |
PostgresSyncTableActionFactory
Factory to create
PostgresSyncTableAction . |
Modifier and Type | Class and Description |
---|---|
class |
PulsarSyncDatabaseActionFactory
Factory to create
PulsarSyncDatabaseAction . |
class |
PulsarSyncTableActionFactory
Factory to create
PulsarSyncTableAction . |
Modifier and Type | Class and Description |
---|---|
class |
KafkaLogStoreFactory
The Kafka
LogStoreTableFactory implementation. |
Modifier and Type | Interface and Description |
---|---|
interface |
LogStoreTableFactory
Base interface for configuring a default log table connector.
|
Modifier and Type | Class and Description |
---|---|
class |
CloneProcedure
Clone Procedure.
|
class |
CompactDatabaseProcedure
Compact database procedure.
|
class |
CompactManifestProcedure
Compact manifest file to reduce deleted manifest entries.
|
class |
CompactProcedure
Compact procedure.
|
class |
CreateBranchProcedure
Create branch procedure for given tag.
|
class |
CreateOrReplaceTagBaseProcedure
A base procedure to create or replace a tag.
|
class |
CreateTagFromTimestampProcedure
The procedure supports creating tags from snapshots commit-time.
|
class |
CreateTagFromWatermarkProcedure
The procedure supports creating tags from snapshots watermark.
|
class |
CreateTagProcedure
Create tag procedure.
|
class |
DeleteBranchProcedure
Delete branch procedure.
|
class |
DeleteTagProcedure
Delete tag procedure.
|
class |
DropPartitionProcedure
Deprecated.
use ALTER TABLE DROP PARTITION
|
class |
ExpirePartitionsProcedure
A procedure to expire partitions.
|
class |
ExpireSnapshotsProcedure
A procedure to expire snapshots.
|
class |
ExpireTagsProcedure
A procedure to expire tags by time.
|
class |
FastForwardProcedure
Fast Forward procedure for given branch.
|
class |
MarkPartitionDoneProcedure
Partition mark done procedure.
|
class |
MergeIntoProcedure
Merge Into procedure.
|
class |
MigrateDatabaseProcedure
Migrate procedure to migrate all hive tables in database to paimon table.
|
class |
MigrateFileProcedure
Add file procedure to add file from hive to paimon.
|
class |
MigrateTableProcedure
Migrate procedure to migrate hive table to paimon table.
|
class |
ProcedureBase
Base implementation for flink
Procedure . |
class |
QueryServiceProcedure
Query Service procedure.
|
class |
RefreshObjectTableProcedure
Refresh Object Table procedure.
|
class |
RemoveOrphanFilesProcedure
Remove orphan files procedure.
|
class |
RenameTagProcedure
Create tag procedure.
|
class |
RepairProcedure
Repair procedure.
|
class |
ReplaceTagProcedure
A procedure to replace a tag.
|
class |
ResetConsumerProcedure
Reset consumer procedure.
|
class |
RewriteFileIndexProcedure
Rewrite file index procedure to re-generated all file index.
|
class |
RollbackToProcedure
Rollback procedure.
|
class |
RollbackToTimestampProcedure
Rollback to timestamp procedure.
|
Modifier and Type | Class and Description |
---|---|
class |
CreatePrivilegedUserProcedure
Procedure to create a user for the privilege system.
|
class |
DropPrivilegedUserProcedure
Procedure to drop a user from the privilege system.
|
class |
GrantPrivilegeToUserProcedure
Procedure to grant privilege to a user.
|
class |
InitFileBasedPrivilegeProcedure
Procedure to initialize file-based privilege system in warehouse.
|
class |
PrivilegeProcedureBase
Base class for privilege-related procedures.
|
class |
RevokePrivilegeFromUserProcedure
Procedure to revoke privilege from a user.
|
Modifier and Type | Class and Description |
---|---|
class |
HiveCatalogFactory
Factory to create
HiveCatalog . |
class |
HiveCatalogLockFactory
Catalog lock factory for hive.
|
Modifier and Type | Interface and Description |
---|---|
interface |
IcebergMetadataCommitterFactory
Factory to create
IcebergMetadataCommitter . |
Modifier and Type | Class and Description |
---|---|
class |
IcebergHiveMetadataCommitterFactory
Factory to create
IcebergHiveMetadataCommitter . |
Modifier and Type | Class and Description |
---|---|
class |
JdbcCatalogFactory
Factory to create
JdbcCatalog . |
class |
JdbcCatalogLockFactory
Jdbc catalog lock factory.
|
Modifier and Type | Interface and Description |
---|---|
interface |
LineageMetaFactory
Factory to create
LineageMeta . |
Modifier and Type | Interface and Description |
---|---|
interface |
FieldAggregatorFactory
Factory for
FieldAggregator . |
Modifier and Type | Class and Description |
---|---|
class |
RESTCatalogFactory
Factory to create
RESTCatalog . |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.