Uses of Class
org.apache.paimon.catalog.Catalog.TableNotExistException

Packages that use Catalog.TableNotExistException

Package	Description
org.apache.paimon.catalog
org.apache.paimon.flink.action
org.apache.paimon.flink.compact
org.apache.paimon.flink.procedure
org.apache.paimon.hive
org.apache.paimon.jdbc
org.apache.paimon.operation
org.apache.paimon.privilege
org.apache.paimon.schema
org.apache.paimon.spark.procedure

Uses of Catalog.TableNotExistException in org.apache.paimon.catalog

Methods in org.apache.paimon.catalog that throw Catalog.TableNotExistException

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)
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)
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)
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)
default void	Catalog.repairTable(Identifier identifier)
void	DelegateCatalog.repairTable(Identifier identifier)

Uses of Catalog.TableNotExistException in org.apache.paimon.flink.action

Constructors in org.apache.paimon.flink.action that throw Catalog.TableNotExistException

Constructor and Description
RemoveOrphanFilesAction(String warehouse, String databaseName, String tableName, Map<String,String> catalogConfig, Map<String,String> dynamicOptions)

Uses of Catalog.TableNotExistException in org.apache.paimon.flink.compact

Methods in org.apache.paimon.flink.compact that throw Catalog.TableNotExistException

Modifier and Type	Method and Description
MultiTableScanBase.ScanResult	MultiTableScanBase.scanTable(org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext<T> ctx)
protected void	MultiTableScanBase.updateTableMap()

Uses of Catalog.TableNotExistException in org.apache.paimon.flink.procedure

Methods in org.apache.paimon.flink.procedure that throw Catalog.TableNotExistException

Modifier and Type	Method and Description
String[]	RepairProcedure.call(org.apache.flink.table.procedure.ProcedureContext procedureContext, String identifier)
String[]	ExpireSnapshotsProcedure.call(org.apache.flink.table.procedure.ProcedureContext procedureContext, String tableId, Integer retainMax, Integer retainMin, String olderThanStr, Integer maxDeletes)
String[]	DropPartitionProcedure.call(org.apache.flink.table.procedure.ProcedureContext procedureContext, String tableId, String... partitionStrings) Deprecated.
String[]	DeleteBranchProcedure.call(org.apache.flink.table.procedure.ProcedureContext procedureContext, String tableId, String branchStr)
String[]	MarkPartitionDoneProcedure.call(org.apache.flink.table.procedure.ProcedureContext procedureContext, String tableId, String partitions)
String[]	FastForwardProcedure.call(org.apache.flink.table.procedure.ProcedureContext procedureContext, String tableId, String branchName)
String[]	DeleteTagProcedure.call(org.apache.flink.table.procedure.ProcedureContext procedureContext, String tableId, String tagNameStr)
String[]	ResetConsumerProcedure.call(org.apache.flink.table.procedure.ProcedureContext procedureContext, String tableId, String consumerId, Long nextSnapshotId)
String[]	RollbackToProcedure.call(org.apache.flink.table.procedure.ProcedureContext procedureContext, String tableId, String tagName, Long snapshotId)
org.apache.flink.types.Row[]	CreateTagFromWatermarkProcedure.call(org.apache.flink.table.procedure.ProcedureContext procedureContext, String tableId, String tagName, Long watermark, String timeRetained)
org.apache.flink.types.Row[]	CreateTagFromTimestampProcedure.call(org.apache.flink.table.procedure.ProcedureContext procedureContext, String tableId, String tagName, Long timestamp, String timeRetained)
String[]	CreateTagProcedure.call(org.apache.flink.table.procedure.ProcedureContext procedureContext, String tableId, String tagName, Long snapshotId, String timeRetained)
String[]	CreateBranchProcedure.call(org.apache.flink.table.procedure.ProcedureContext procedureContext, String tableId, String branchName, String tagName)
org.apache.flink.types.Row[]	ExpirePartitionsProcedure.call(org.apache.flink.table.procedure.ProcedureContext procedureContext, String tableId, String expirationTime, String timestampFormatter, String timestampPattern, String expireStrategy)
void	RepairProcedure.repairDatabasesOrTables(String databaseOrTables)
protected Table	ProcedureBase.table(String tableId)

Uses of Catalog.TableNotExistException in org.apache.paimon.hive

Methods in org.apache.paimon.hive that throw Catalog.TableNotExistException

Modifier and Type	Method and Description
protected void	HiveCatalog.alterTableImpl(Identifier identifier, List<SchemaChange> changes)
void	HiveCatalog.dropPartition(Identifier identifier, Map<String,String> partitionSpec)
TableSchema	HiveCatalog.getDataTableSchema(Identifier identifier)
FormatTable	HiveCatalog.getFormatTable(Identifier identifier)
void	HiveCatalog.repairTable(Identifier identifier)

Uses of Catalog.TableNotExistException in org.apache.paimon.jdbc

Methods in org.apache.paimon.jdbc that throw Catalog.TableNotExistException

Modifier and Type	Method and Description
protected void	JdbcCatalog.alterTableImpl(Identifier identifier, List<SchemaChange> changes)
protected TableSchema	JdbcCatalog.getDataTableSchema(Identifier identifier)

Uses of Catalog.TableNotExistException in org.apache.paimon.operation

Methods in org.apache.paimon.operation that throw Catalog.TableNotExistException

Modifier and Type	Method and Description
static List<OrphanFilesClean>	OrphanFilesClean.createOrphanFilesCleans(Catalog catalog, Map<String,String> tableConfig, String databaseName, String tableName)

Uses of Catalog.TableNotExistException in org.apache.paimon.privilege

Methods in org.apache.paimon.privilege that throw Catalog.TableNotExistException

Modifier and Type	Method and Description
void	PrivilegedCatalog.alterTable(Identifier identifier, List<SchemaChange> changes, boolean ignoreIfNotExists)
void	PrivilegedCatalog.dropPartition(Identifier identifier, Map<String,String> partitions)
void	PrivilegedCatalog.dropTable(Identifier identifier, boolean ignoreIfNotExists)
Table	PrivilegedCatalog.getTable(Identifier identifier)
void	PrivilegedCatalog.renameTable(Identifier fromTable, Identifier toTable, boolean ignoreIfNotExists)

Uses of Catalog.TableNotExistException in org.apache.paimon.schema

Methods in org.apache.paimon.schema that throw Catalog.TableNotExistException

Modifier and Type	Method and Description
TableSchema	SchemaManager.commitChanges(List<SchemaChange> changes) Update SchemaChanges.

Uses of Catalog.TableNotExistException in org.apache.paimon.spark.procedure

Methods in org.apache.paimon.spark.procedure that throw Catalog.TableNotExistException

Modifier and Type	Method and Description
void	RepairProcedure.repairDatabasesOrTables(String databaseOrTables, Catalog paimonCatalog)