Uses of Class
org.apache.paimon.catalog.Identifier

Packages that use Identifier

Package	Description
org.apache.paimon.append
org.apache.paimon.catalog
org.apache.paimon.flink
org.apache.paimon.flink.action
org.apache.paimon.flink.action.cdc
org.apache.paimon.flink.action.cdc.mysql
org.apache.paimon.flink.action.cdc.postgres
org.apache.paimon.flink.action.cdc.schema
org.apache.paimon.flink.compact
org.apache.paimon.flink.log
org.apache.paimon.flink.sink
org.apache.paimon.flink.sink.cdc
org.apache.paimon.flink.utils
org.apache.paimon.hive
org.apache.paimon.io
org.apache.paimon.jdbc
org.apache.paimon.manifest
org.apache.paimon.operation
org.apache.paimon.privilege
org.apache.paimon.schema
org.apache.paimon.spark
org.apache.paimon.table

Uses of Identifier in org.apache.paimon.append

Methods in org.apache.paimon.append that return Identifier

Modifier and Type	Method and Description
Identifier	MultiTableUnawareAppendCompactionTask.tableIdentifier()

Constructors in org.apache.paimon.append with parameters of type Identifier

Constructor and Description
MultiTableUnawareAppendCompactionTask(BinaryRow partition, List<DataFileMeta> files, Identifier identifier)

Uses of Identifier in org.apache.paimon.catalog

Fields in org.apache.paimon.catalog with type parameters of type Identifier

Modifier and Type	Field and Description
protected org.apache.paimon.shade.caffeine2.com.github.benmanes.caffeine.cache.Cache<Identifier,Table>	CachingCatalog.tableCache

Methods in org.apache.paimon.catalog that return Identifier

Modifier and Type	Method and Description
static Identifier	Identifier.create(String db, String object)
static Identifier	Identifier.fromString(String fullName)
Identifier	Catalog.TableAlreadyExistException.identifier()
Identifier	Catalog.TableNotExistException.identifier()
Identifier	Catalog.PartitionNotExistException.identifier()
Identifier	Catalog.ColumnAlreadyExistException.identifier()
Identifier	Catalog.ColumnNotExistException.identifier()

Methods in org.apache.paimon.catalog with parameters of type Identifier

Modifier and Type	Method and Description
void	CachingCatalog.alterTable(Identifier identifier, List<SchemaChange> changes, boolean ignoreIfNotExists)
void	Catalog.alterTable(Identifier identifier, List<SchemaChange> changes, boolean ignoreIfNotExists) Modify an existing table from SchemaChanges.
void	AbstractCatalog.alterTable(Identifier identifier, List<SchemaChange> changes, boolean ignoreIfNotExists)
void	DelegateCatalog.alterTable(Identifier identifier, List<SchemaChange> changes, boolean ignoreIfNotExists)
default void	Catalog.alterTable(Identifier identifier, SchemaChange change, boolean ignoreIfNotExists) Modify an existing table from a SchemaChange.
protected void	FileSystemCatalog.alterTableImpl(Identifier identifier, List<SchemaChange> changes)
protected abstract void	AbstractCatalog.alterTableImpl(Identifier identifier, List<SchemaChange> changes)
protected void	AbstractCatalog.assertMainBranch(Identifier identifier)
protected static void	AbstractCatalog.checkNotBranch(Identifier identifier, String method)
protected static void	AbstractCatalog.checkNotSystemTable(Identifier identifier, String method)
void	Catalog.createTable(Identifier identifier, Schema schema, boolean ignoreIfExists) Create a new table.
void	AbstractCatalog.createTable(Identifier identifier, Schema schema, boolean ignoreIfExists)
void	DelegateCatalog.createTable(Identifier identifier, Schema schema, boolean ignoreIfExists)
void	FileSystemCatalog.createTableImpl(Identifier identifier, Schema schema)
protected abstract void	AbstractCatalog.createTableImpl(Identifier identifier, Schema schema)
void	Catalog.dropPartition(Identifier identifier, Map<String,String> partitions) Drop the partition of the specify table.
void	AbstractCatalog.dropPartition(Identifier identifier, Map<String,String> partitionSpec)
void	DelegateCatalog.dropPartition(Identifier identifier, Map<String,String> partitions)
void	CachingCatalog.dropTable(Identifier identifier, boolean ignoreIfNotExists)
void	Catalog.dropTable(Identifier identifier, boolean ignoreIfNotExists) Drop a table.
void	AbstractCatalog.dropTable(Identifier identifier, boolean ignoreIfNotExists)
void	DelegateCatalog.dropTable(Identifier identifier, boolean ignoreIfNotExists)
protected void	FileSystemCatalog.dropTableImpl(Identifier identifier)
protected abstract void	AbstractCatalog.dropTableImpl(Identifier identifier)
TableSchema	FileSystemCatalog.getDataTableSchema(Identifier identifier)
protected abstract TableSchema	AbstractCatalog.getDataTableSchema(Identifier identifier)
FormatTable	AbstractCatalog.getFormatTable(Identifier identifier) Return a FormatTable identified by the given Identifier.
Table	CachingCatalog.getTable(Identifier identifier)
Table	Catalog.getTable(Identifier identifier) Return a Table identified by the given Identifier.
Table	AbstractCatalog.getTable(Identifier identifier)
Table	DelegateCatalog.getTable(Identifier identifier)
Path	Catalog.getTableLocation(Identifier identifier) Get the table location in this catalog.
Path	AbstractCatalog.getTableLocation(Identifier identifier)
Path	DelegateCatalog.getTableLocation(Identifier identifier)
void	CachingCatalog.invalidateTable(Identifier identifier)
default void	Catalog.invalidateTable(Identifier identifier) Invalidate cached table metadata for an identifier.
static boolean	AbstractCatalog.isSpecifiedSystemTable(Identifier identifier)
protected static boolean	AbstractCatalog.isSystemTable(Identifier identifier)
default Optional<MetastoreClient.Factory>	Catalog.metastoreClientFactory(Identifier identifier) Get metastore client factory for the table specified by identifier.
Optional<MetastoreClient.Factory>	DelegateCatalog.metastoreClientFactory(Identifier identifier)
static Path	AbstractCatalog.newTableLocation(String warehouse, Identifier identifier)
void	CachingCatalog.renameTable(Identifier fromTable, Identifier toTable, boolean ignoreIfNotExists)
void	Catalog.renameTable(Identifier fromTable, Identifier toTable, boolean ignoreIfNotExists) Rename a table.
void	AbstractCatalog.renameTable(Identifier fromTable, Identifier toTable, boolean ignoreIfNotExists)
void	DelegateCatalog.renameTable(Identifier fromTable, Identifier toTable, boolean ignoreIfNotExists)
void	FileSystemCatalog.renameTableImpl(Identifier fromTable, Identifier toTable)
protected abstract void	AbstractCatalog.renameTableImpl(Identifier fromTable, Identifier toTable)
default void	Catalog.repairTable(Identifier identifier)
void	DelegateCatalog.repairTable(Identifier identifier)
boolean	FileSystemCatalog.tableExists(Identifier identifier)
default boolean	Catalog.tableExists(Identifier identifier) Check if a table exists in this catalog.
protected void	AbstractCatalog.validateIdentifierNameCaseInsensitive(Identifier identifier)

Constructors in org.apache.paimon.catalog with parameters of type Identifier

Constructor and Description
ColumnAlreadyExistException(Identifier identifier, String column)
ColumnAlreadyExistException(Identifier identifier, String column, Throwable cause)
ColumnNotExistException(Identifier identifier, String column)
ColumnNotExistException(Identifier identifier, String column, Throwable cause)
PartitionNotExistException(Identifier identifier, Map<String,String> partitionSpec)
PartitionNotExistException(Identifier identifier, Map<String,String> partitionSpec, Throwable cause)
TableAlreadyExistException(Identifier identifier)
TableAlreadyExistException(Identifier identifier, Throwable cause)
TableNotExistException(Identifier identifier)
TableNotExistException(Identifier identifier, Throwable cause)

Uses of Identifier in org.apache.paimon.flink

Methods in org.apache.paimon.flink that return Identifier

Modifier and Type	Method and Description
static Identifier	FlinkCatalog.toIdentifier(org.apache.flink.table.catalog.ObjectPath path)

Methods in org.apache.paimon.flink with parameters of type Identifier

Modifier and Type	Method and Description
protected Schema	FlinkCatalog.buildPaimonSchema(Identifier identifier, org.apache.flink.table.catalog.CatalogTable catalogTable, Map<String,String> options)

Uses of Identifier in org.apache.paimon.flink.action

Fields in org.apache.paimon.flink.action declared as Identifier

Modifier and Type	Field and Description
protected Identifier	TableActionBase.identifier

Uses of Identifier in org.apache.paimon.flink.action.cdc

Methods in org.apache.paimon.flink.action.cdc with parameters of type Identifier

Modifier and Type	Method and Description
protected FileStoreTable	SynchronizationActionBase.alterTableOptions(Identifier identifier, FileStoreTable table)
String	TableNameConverter.convert(Identifier originIdentifier)

Method parameters in org.apache.paimon.flink.action.cdc with type arguments of type Identifier

Modifier and Type	Method and Description
static String	CdcActionCommonUtils.combinedModeTableList(String databasePattern, String includingTablePattern, List<Identifier> excludedTables)
static String	CdcActionCommonUtils.tableList(MultiTablesSinkMode mode, String databasePattern, String includingTablePattern, List<Identifier> monitoredTables, List<Identifier> excludedTables)
static String	CdcActionCommonUtils.tableList(MultiTablesSinkMode mode, String databasePattern, String includingTablePattern, List<Identifier> monitoredTables, List<Identifier> excludedTables)

Uses of Identifier in org.apache.paimon.flink.action.cdc.mysql

Methods in org.apache.paimon.flink.action.cdc.mysql that return types with arguments of type Identifier

Modifier and Type	Method and Description
List<Identifier>	MySqlSyncDatabaseAction.excludedTables()
List<Identifier>	MySqlSyncDatabaseAction.monitoredTables()

Method parameters in org.apache.paimon.flink.action.cdc.mysql with type arguments of type Identifier

Modifier and Type	Method and Description
static JdbcSchemasInfo	MySqlActionUtils.getMySqlTableInfos(org.apache.flink.configuration.Configuration mySqlConfig, java.util.function.Predicate<String> monitorTablePredication, List<Identifier> excludedTables, TypeMapping typeMapping)

Uses of Identifier in org.apache.paimon.flink.action.cdc.postgres

Method parameters in org.apache.paimon.flink.action.cdc.postgres with type arguments of type Identifier

Modifier and Type	Method and Description
static JdbcSchemasInfo	PostgresActionUtils.getPostgresTableInfos(org.apache.flink.configuration.Configuration postgresConfig, java.util.function.Predicate<String> monitorTablePredication, List<Identifier> excludedTables, TypeMapping typeMapping)

Uses of Identifier in org.apache.paimon.flink.action.cdc.schema

Methods in org.apache.paimon.flink.action.cdc.schema that return Identifier

Modifier and Type	Method and Description
Identifier	JdbcSchemasInfo.JdbcSchemaInfo.identifier()

Methods in org.apache.paimon.flink.action.cdc.schema that return types with arguments of type Identifier

Modifier and Type	Method and Description
List<Identifier>	AllMergedJdbcTableInfo.identifiers()
List<Identifier>	UnmergedJdbcTableInfo.identifiers()
List<Identifier>	JdbcTableInfo.identifiers() Return all MySQL table identifiers that build this schema.
List<Identifier>	ShardsMergedJdbcTableInfo.identifiers()
List<Identifier>	JdbcSchemasInfo.nonPkTables()

Methods in org.apache.paimon.flink.action.cdc.schema with parameters of type Identifier

Modifier and Type	Method and Description
void	JdbcSchemasInfo.addSchema(Identifier identifier, Schema schema)
void	JdbcSchemasInfo.addSchema(Identifier identifier, String schemaName, Schema schema)
void	AllMergedJdbcTableInfo.init(Identifier identifier, Schema schema)
void	ShardsMergedJdbcTableInfo.init(Identifier identifier, Schema schema)
AllMergedJdbcTableInfo	AllMergedJdbcTableInfo.merge(Identifier otherTableId, Schema other)
ShardsMergedJdbcTableInfo	ShardsMergedJdbcTableInfo.merge(Identifier otherTableId, Schema other)

Constructors in org.apache.paimon.flink.action.cdc.schema with parameters of type Identifier

Constructor and Description
JdbcSchemaInfo(Identifier identifier, String schemaName, boolean isPkTable, Schema schema)
UnmergedJdbcTableInfo(Identifier identifier, Schema schema)

Uses of Identifier in org.apache.paimon.flink.compact

Fields in org.apache.paimon.flink.compact with type parameters of type Identifier

Modifier and Type	Field and Description
protected Map<Identifier,StreamTableScan>	MultiAwareBucketTableScan.scansMap
protected Map<Identifier,UnawareAppendTableCompactionCoordinator>	MultiUnawareBucketTableScan.tablesMap
protected Map<Identifier,CompactBucketsTable>	MultiAwareBucketTableScan.tablesMap

Methods in org.apache.paimon.flink.compact with parameters of type Identifier

Modifier and Type	Method and Description
void	MultiUnawareBucketTableScan.addScanTable(FileStoreTable fileStoreTable, Identifier identifier)
void	MultiAwareBucketTableScan.addScanTable(FileStoreTable fileStoreTable, Identifier identifier)
boolean	MultiUnawareBucketTableScan.checkTableScanned(Identifier identifier)
boolean	MultiAwareBucketTableScan.checkTableScanned(Identifier identifier)

Uses of Identifier in org.apache.paimon.flink.log

Methods in org.apache.paimon.flink.log that return Identifier

Modifier and Type	Method and Description
Identifier	LogStoreTableFactory.RegisterContext.getIdentifier() Identifier for the table.

Methods in org.apache.paimon.flink.log with parameters of type Identifier

Modifier and Type	Method and Description
static LogStoreRegister	LogStoreRegister.getLogStoreRegister(Identifier identifier, ClassLoader classLoader, Options tableOptions, String logStore)
static void	LogStoreRegister.registerLogSystem(Catalog catalog, Identifier identifier, Map<String,String> options, ClassLoader classLoader)
static void	LogStoreRegister.unRegisterLogSystem(Identifier identifier, Map<String,String> options, ClassLoader classLoader)

Uses of Identifier in org.apache.paimon.flink.sink

Fields in org.apache.paimon.flink.sink with type parameters of type Identifier

Modifier and Type	Field and Description
protected Map<Identifier,FileStoreTable>	MultiTablesStoreCompactOperator.tables
protected Map<Identifier,StoreSinkWrite>	MultiTablesStoreCompactOperator.writes

Methods in org.apache.paimon.flink.sink with parameters of type Identifier

Modifier and Type	Method and Description
static MultiTableCommittable	MultiTableCommittable.fromCommittable(Identifier id, Committable committable)

Uses of Identifier in org.apache.paimon.flink.sink.cdc

Fields in org.apache.paimon.flink.sink.cdc with type parameters of type Identifier

Modifier and Type	Field and Description
static org.apache.flink.util.OutputTag<org.apache.flink.api.java.tuple.Tuple2<Identifier,List<DataField>>>	CdcDynamicTableParsingProcessFunction.DYNAMIC_SCHEMA_CHANGE_OUTPUT_TAG

Methods in org.apache.paimon.flink.sink.cdc that return types with arguments of type Identifier

Modifier and Type	Method and Description
Map<Identifier,FileStoreTable>	CdcRecordStoreMultiWriteOperator.tables()
Map<Identifier,StoreSinkWrite>	CdcRecordStoreMultiWriteOperator.writes()

Methods in org.apache.paimon.flink.sink.cdc with parameters of type Identifier

Modifier and Type	Method and Description
protected void	UpdatedDataFieldsProcessFunctionBase.applySchemaChange(SchemaManager schemaManager, SchemaChange schemaChange, Identifier identifier)
RichCdcSinkBuilder	RichCdcSinkBuilder.identifier(Identifier identifier)
RichCdcSinkBuilder	RichCdcSinkBuilder.withIdentifier(Identifier identifier) Deprecated. Use RichCdcSinkBuilder.identifier.
CdcSinkBuilder<T>	CdcSinkBuilder.withIdentifier(Identifier identifier)

Method parameters in org.apache.paimon.flink.sink.cdc with type arguments of type Identifier

Modifier and Type	Method and Description
void	MultiTableUpdatedDataFieldsProcessFunction.processElement(org.apache.flink.api.java.tuple.Tuple2<Identifier,List<DataField>> updatedDataFields, org.apache.flink.streaming.api.functions.ProcessFunction.Context context, org.apache.flink.util.Collector<Void> collector)

Constructors in org.apache.paimon.flink.sink.cdc with parameters of type Identifier

Constructor and Description
UpdatedDataFieldsProcessFunction(SchemaManager schemaManager, Identifier identifier, Catalog.Loader catalogLoader)

Uses of Identifier in org.apache.paimon.flink.utils

Methods in org.apache.paimon.flink.utils with parameters of type Identifier

Modifier and Type	Method and Description
static boolean	MultiTablesCompactorUtil.shouldCompactTable(Identifier tableIdentifier, Pattern includingPattern, Pattern excludingPattern)

Uses of Identifier in org.apache.paimon.hive

Methods in org.apache.paimon.hive with parameters of type Identifier

Modifier and Type	Method and Description
protected void	HiveCatalog.alterTableImpl(Identifier identifier, List<SchemaChange> changes)
protected void	HiveCatalog.createTableImpl(Identifier identifier, Schema schema)
void	HiveCatalog.dropPartition(Identifier identifier, Map<String,String> partitionSpec)
protected void	HiveCatalog.dropTableImpl(Identifier identifier)
TableSchema	HiveCatalog.getDataTableSchema(Identifier identifier)
FormatTable	HiveCatalog.getFormatTable(Identifier identifier)
Path	HiveCatalog.getTableLocation(Identifier identifier)
Optional<MetastoreClient.Factory>	HiveCatalog.metastoreClientFactory(Identifier identifier)
protected void	HiveCatalog.renameTableImpl(Identifier fromTable, Identifier toTable)
void	HiveCatalog.repairTable(Identifier identifier)
boolean	HiveCatalog.tableExists(Identifier identifier)

Constructors in org.apache.paimon.hive with parameters of type Identifier

Constructor and Description
Factory(Identifier identifier, TableSchema schema, org.apache.hadoop.hive.conf.HiveConf hiveConf, String clientClassName, Options options)

Uses of Identifier in org.apache.paimon.io

Methods in org.apache.paimon.io that return Identifier

Modifier and Type	Method and Description
Identifier	IdentifierSerializer.fromRow(InternalRow rowData)

Methods in org.apache.paimon.io with parameters of type Identifier

Modifier and Type	Method and Description
InternalRow	IdentifierSerializer.toRow(Identifier record)

Uses of Identifier in org.apache.paimon.jdbc

Methods in org.apache.paimon.jdbc with parameters of type Identifier

Modifier and Type	Method and Description
protected void	JdbcCatalog.alterTableImpl(Identifier identifier, List<SchemaChange> changes)
protected void	JdbcCatalog.createTableImpl(Identifier identifier, Schema schema)
protected void	JdbcCatalog.dropTableImpl(Identifier identifier)
protected TableSchema	JdbcCatalog.getDataTableSchema(Identifier identifier)
protected void	JdbcCatalog.renameTableImpl(Identifier fromTable, Identifier toTable)
static void	JdbcUtils.updateTable(JdbcClientPool connections, String storeKey, Identifier fromTable, Identifier toTable)

Uses of Identifier in org.apache.paimon.manifest

Methods in org.apache.paimon.manifest that return types with arguments of type Identifier

Modifier and Type	Method and Description
Map<Identifier,ManifestCommittable>	WrappedManifestCommittable.manifestCommittables()

Methods in org.apache.paimon.manifest with parameters of type Identifier

Modifier and Type	Method and Description
ManifestCommittable	WrappedManifestCommittable.computeCommittableIfAbsent(Identifier identifier, long checkpointId, long watermark)
void	WrappedManifestCommittable.putManifestCommittable(Identifier identifier, ManifestCommittable manifestCommittable)

Uses of Identifier in org.apache.paimon.operation

Methods in org.apache.paimon.operation with parameters of type Identifier

Modifier and Type	Method and Description
static Lock.Factory	Lock.factory(CatalogLockFactory lockFactory, CatalogLockContext lockContext, Identifier tablePath)
static Lock	Lock.fromCatalog(CatalogLock lock, Identifier tablePath)

Constructors in org.apache.paimon.operation with parameters of type Identifier

Constructor and Description
LockFactory(CatalogLockFactory lockFactory, CatalogLockContext lockContext, Identifier tablePath)

Uses of Identifier in org.apache.paimon.privilege

Methods in org.apache.paimon.privilege with parameters of type Identifier

Modifier and Type	Method and Description
void	PrivilegedCatalog.alterTable(Identifier identifier, List<SchemaChange> changes, boolean ignoreIfNotExists)
void	PrivilegeChecker.assertCanAlterTable(Identifier identifier)
void	PrivilegeCheckerImpl.assertCanAlterTable(Identifier identifier)
void	AllGrantedPrivilegeChecker.assertCanAlterTable(Identifier identifier)
void	PrivilegeChecker.assertCanDropTable(Identifier identifier)
void	PrivilegeCheckerImpl.assertCanDropTable(Identifier identifier)
void	AllGrantedPrivilegeChecker.assertCanDropTable(Identifier identifier)
void	PrivilegeChecker.assertCanInsert(Identifier identifier)
void	PrivilegeCheckerImpl.assertCanInsert(Identifier identifier)
void	AllGrantedPrivilegeChecker.assertCanInsert(Identifier identifier)
void	PrivilegeChecker.assertCanSelect(Identifier identifier)
void	PrivilegeCheckerImpl.assertCanSelect(Identifier identifier)
void	AllGrantedPrivilegeChecker.assertCanSelect(Identifier identifier)
void	PrivilegedCatalog.createTable(Identifier identifier, Schema schema, boolean ignoreIfExists)
void	PrivilegedCatalog.dropPartition(Identifier identifier, Map<String,String> partitions)
void	PrivilegedCatalog.dropTable(Identifier identifier, boolean ignoreIfNotExists)
Table	PrivilegedCatalog.getTable(Identifier identifier)
void	PrivilegedCatalog.grantPrivilegeOnTable(String user, Identifier identifier, PrivilegeType privilege)
void	PrivilegedCatalog.renameTable(Identifier fromTable, Identifier toTable, boolean ignoreIfNotExists)
int	PrivilegedCatalog.revokePrivilegeOnTable(String user, Identifier identifier, PrivilegeType privilege) Returns the number of privilege revoked.

Constructors in org.apache.paimon.privilege with parameters of type Identifier

Constructor and Description
PrivilegedFileStore(FileStore<T> wrapped, PrivilegeChecker privilegeChecker, Identifier identifier)
PrivilegedFileStoreTable(FileStoreTable wrapped, PrivilegeChecker privilegeChecker, Identifier identifier)

Uses of Identifier in org.apache.paimon.schema

Methods in org.apache.paimon.schema that return Identifier

Modifier and Type	Method and Description
static Identifier	SchemaManager.identifierFromPath(String tablePath, boolean ignoreIfUnknownDatabase)
static Identifier	SchemaManager.identifierFromPath(String tablePath, boolean ignoreIfUnknownDatabase, String branchName)

Uses of Identifier in org.apache.paimon.spark

Methods in org.apache.paimon.spark that return Identifier

Modifier and Type	Method and Description
protected Identifier	SparkCatalog.toIdentifier(org.apache.spark.sql.connector.catalog.Identifier ident)

Uses of Identifier in org.apache.paimon.table

Methods in org.apache.paimon.table that return Identifier

Modifier and Type	Method and Description
Identifier	CatalogEnvironment.identifier()

Methods in org.apache.paimon.table with parameters of type Identifier

Modifier and Type	Method and Description
FormatTable.Builder	FormatTable.Builder.identifier(Identifier identifier)

Constructors in org.apache.paimon.table with parameters of type Identifier

Constructor and Description
CatalogEnvironment(Identifier identifier, Lock.Factory lockFactory, MetastoreClient.Factory metastoreClientFactory, LineageMetaFactory lineageMetaFactory)
FormatTableImpl(Identifier identifier, RowType rowType, List<String> partitionKeys, String location, FormatTable.Format format, Map<String,String> options, String comment)