org.apache.paimon.factories

Interface Factory

All Known Subinterfaces:

ActionFactory, CatalogFactory, CatalogLockFactory, DataFormatFactory, FieldAggregatorFactory, IcebergMetadataCommitterFactory, LineageMetaFactory, LogStoreTableFactory

All Known Implementing Classes:

CanalDataFormatFactory, CloneActionFactory, CloneProcedure, CompactActionFactory, CompactDatabaseActionFactory, CompactDatabaseProcedure, CompactManifestProcedure, CompactProcedure, CreateBranchActionFactory, CreateBranchProcedure, CreateOrReplaceTagActionFactory, CreateOrReplaceTagBaseProcedure, CreatePrivilegedUserProcedure, CreateTagActionFactory, CreateTagFromTimestampActionFactory, CreateTagFromTimestampProcedure, CreateTagFromWatermarkActionFactory, CreateTagFromWatermarkProcedure, CreateTagProcedure, DebeziumAvroDataFormatFactory, DebeziumJsonDataFormatFactory, DeleteActionFactory, DeleteBranchActionFactory, DeleteBranchProcedure, DeleteTagActionFactory, DeleteTagProcedure, DMSDataFormatFactory, DropPartitionActionFactory, DropPartitionProcedure, DropPrivilegedUserProcedure, ExpirePartitionsActionFactory, ExpirePartitionsProcedure, ExpireSnapshotsActionFactory, ExpireSnapshotsProcedure, ExpireTagsActionFactory, ExpireTagsProcedure, FastForwardActionFactory, FastForwardProcedure, FieldBoolAndAggFactory, FieldBoolOrAggFactory, FieldCollectAggFactory, FieldFirstNonNullValueAggFactory, FieldFirstNonNullValueAggLegacyFactory, FieldFirstValueAggFactory, FieldHllSketchAggFactory, FieldLastNonNullValueAggFactory, FieldLastValueAggFactory, FieldListaggAggFactory, FieldMaxAggFactory, FieldMergeMapAggFactory, FieldMinAggFactory, FieldNestedUpdateAggFactory, FieldPrimaryKeyAggFactory, FieldProductAggFactory, FieldRoaringBitmap32AggFactory, FieldRoaringBitmap64AggFactory, FieldSumAggFactory, FieldThetaSketchAggFactory, FileSystemCatalogFactory, GrantPrivilegeToUserProcedure, HiveCatalogFactory, HiveCatalogLockFactory, IcebergHiveMetadataCommitterFactory, InitFileBasedPrivilegeProcedure, JdbcCatalogFactory, JdbcCatalogLockFactory, JsonDataFormatFactory, KafkaLogStoreFactory, KafkaSyncDatabaseActionFactory, KafkaSyncTableActionFactory, MarkPartitionDoneActionFactory, MarkPartitionDoneProcedure, MaxwellDataFormatFactory, MergeIntoActionFactory, MergeIntoProcedure, MigrateDatabaseActionFactory, MigrateDatabaseProcedure, MigrateFileActionFactory, MigrateFileProcedure, MigrateTableActionFactory, MigrateTableProcedure, MongoDBSyncDatabaseActionFactory, MongoDBSyncTableActionFactory, MySqlSyncDatabaseActionFactory, MySqlSyncTableActionFactory, OggDataFormatFactory, PostgresSyncTableActionFactory, PrivilegeProcedureBase, ProcedureBase, PulsarSyncDatabaseActionFactory, PulsarSyncTableActionFactory, QueryServiceActionFactory, QueryServiceProcedure, RemoveOrphanFilesActionFactory, RemoveOrphanFilesProcedure, RenameTagActionFactory, RenameTagProcedure, RepairActionFactory, RepairProcedure, ReplaceTagActionFactory, ReplaceTagProcedure, ResetConsumerActionFactory, ResetConsumerProcedure, RevokePrivilegeFromUserProcedure, RewriteFileIndexActionFactory, RewriteFileIndexProcedure, RollbackToActionFactory, RollbackToProcedure, RollbackToTimestampActionFactory, RollbackToTimestampProcedure, SyncDatabaseActionFactoryBase, SynchronizationActionFactoryBase, SyncTableActionFactoryBase

public interface Factory

Base interface for all kind of factories that create object instances from a list of key-value pairs in Paimon's catalog, lineage.

A factory is uniquely identified by Class and identifier().

The list of available factories is discovered using Java's Service Provider Interfaces (SPI). Classes that implement this interface can be added to META_INF/services/org.apache.paimon.factories.Factory in JAR files.

Method Summary

Modifier and Type	Method and Description
String	identifier() Returns a unique identifier among same factory interfaces.

Method Detail

identifier

String identifier()

Returns a unique identifier among same factory interfaces.

For consistency, an identifier should be declared as one lower case word (e.g. kafka). If multiple factories exist for different versions, a version should be appended using "-" (e.g. elasticsearch-7).