Uses of Interface
org.apache.paimon.catalog.Catalog

Packages that use Catalog

Package	Description
org.apache.paimon.catalog
org.apache.paimon.flink
org.apache.paimon.flink.action
org.apache.paimon.flink.compact
org.apache.paimon.flink.log
org.apache.paimon.flink.orphan
org.apache.paimon.flink.procedure
org.apache.paimon.flink.sink
org.apache.paimon.flink.sink.cdc
org.apache.paimon.flink.utils
org.apache.paimon.hive
org.apache.paimon.jdbc
org.apache.paimon.operation
org.apache.paimon.privilege
org.apache.paimon.spark
org.apache.paimon.spark.catalog
org.apache.paimon.spark.procedure
org.apache.paimon.spark.utils

Uses of Catalog in org.apache.paimon.catalog

Classes in org.apache.paimon.catalog that implement Catalog

Modifier and Type	Class and Description
class	AbstractCatalog Common implementation of Catalog.
class	CachingCatalog A Catalog to cache databases and tables and manifests.
class	DelegateCatalog A Catalog to delegate all operations to another Catalog.
class	FileSystemCatalog A catalog implementation for FileIO.

Fields in org.apache.paimon.catalog declared as Catalog

Modifier and Type	Field and Description
protected Catalog	DelegateCatalog.wrapped

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

Modifier and Type	Method and Description
default Catalog	CatalogFactory.create(CatalogContext context)
Catalog	FileSystemCatalogFactory.create(FileIO fileIO, Path warehouse, CatalogContext context)
default Catalog	CatalogFactory.create(FileIO fileIO, Path warehouse, CatalogContext context)
static Catalog	CatalogFactory.createCatalog(CatalogContext options) If the ClassLoader is not specified, using the context ClassLoader of current thread as default.
static Catalog	CatalogFactory.createCatalog(CatalogContext context, ClassLoader classLoader)
static Catalog	CatalogFactory.createUnwrappedCatalog(CatalogContext context, ClassLoader classLoader)
Catalog	Catalog.Loader.load()
static Catalog	CachingCatalog.tryToCreate(Catalog catalog, Options options)
Catalog	DelegateCatalog.wrapped()

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

Modifier and Type	Method and Description
static Catalog	CachingCatalog.tryToCreate(Catalog catalog, Options options)

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

Constructor and Description
CachingCatalog(Catalog wrapped)
CachingCatalog(Catalog wrapped, java.time.Duration expirationInterval, MemorySize manifestMaxMemory, long manifestCacheThreshold, long cachedPartitionMaxNum, int snapshotMaxNumPerTable)
CachingCatalog(Catalog wrapped, java.time.Duration expirationInterval, MemorySize manifestMaxMemory, long manifestCacheThreshold, long cachedPartitionMaxNum, int snapshotMaxNumPerTable, org.apache.paimon.shade.caffeine2.com.github.benmanes.caffeine.cache.Ticker ticker)
DelegateCatalog(Catalog wrapped)

Uses of Catalog in org.apache.paimon.flink

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

Modifier and Type	Method and Description
Catalog	FlinkCatalog.catalog()
static Catalog	FlinkCatalogFactory.createPaimonCatalog(Options catalogOptions)

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

Modifier and Type	Method and Description
static FlinkCatalog	FlinkCatalogFactory.createCatalog(String catalogName, Catalog catalog, Options options)

Constructors in org.apache.paimon.flink with parameters of type Catalog

Constructor and Description
FlinkCatalog(Catalog catalog, String name, String defaultDatabase, ClassLoader classLoader, Options options)

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

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

Modifier and Type	Field and Description
protected Catalog	ActionBase.catalog

Methods in org.apache.paimon.flink.action that return Catalog

Modifier and Type	Method and Description
protected Catalog	ActionBase.initPaimonCatalog()

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

Fields in org.apache.paimon.flink.compact declared as Catalog

Modifier and Type	Field and Description
protected Catalog	MultiTableScanBase.catalog

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

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

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

Uses of Catalog in org.apache.paimon.flink.orphan

Methods in org.apache.paimon.flink.orphan with parameters of type Catalog

Modifier and Type	Method and Description
static long	FlinkOrphanFilesClean.executeDatabaseOrphanFiles(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, Catalog catalog, long olderThanMillis, SerializableConsumer<Path> fileCleaner, Integer parallelism, String databaseName, String tableName)

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

Fields in org.apache.paimon.flink.procedure declared as Catalog

Modifier and Type	Field and Description
protected Catalog	ProcedureBase.catalog

Methods in org.apache.paimon.flink.procedure with parameters of type Catalog

Modifier and Type	Method and Description
static Optional<org.apache.flink.table.procedures.Procedure>	ProcedureUtil.getProcedure(Catalog catalog, org.apache.flink.table.catalog.ObjectPath procedurePath)
ProcedureBase	ProcedureBase.withCatalog(Catalog catalog)

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

Fields in org.apache.paimon.flink.sink declared as Catalog

Modifier and Type	Field and Description
protected Catalog	MultiTablesStoreCompactOperator.catalog

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

Fields in org.apache.paimon.flink.sink.cdc declared as Catalog

Modifier and Type	Field and Description
protected Catalog	UpdatedDataFieldsProcessFunctionBase.catalog

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

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

Modifier and Type	Method and Description
static Migrator	TableMigrationUtils.getImporter(String connector, Catalog catalog, String sourceDatabase, String sourceTableName, String targetDatabase, String targetTableName, Integer parallelism, Map<String,String> options)
static List<Migrator>	TableMigrationUtils.getImporters(String connector, Catalog catalog, String sourceDatabase, Integer parallelism, Map<String,String> options)

Uses of Catalog in org.apache.paimon.hive

Classes in org.apache.paimon.hive that implement Catalog

Modifier and Type	Class and Description
class	HiveCatalog A catalog implementation for Hive.

Methods in org.apache.paimon.hive that return Catalog

Modifier and Type	Method and Description
Catalog	HiveCatalogFactory.create(CatalogContext context)
static Catalog	HiveCatalog.createHiveCatalog(CatalogContext context)

Uses of Catalog in org.apache.paimon.jdbc

Classes in org.apache.paimon.jdbc that implement Catalog

Modifier and Type	Class and Description
class	JdbcCatalog Support jdbc catalog.

Methods in org.apache.paimon.jdbc that return Catalog

Modifier and Type	Method and Description
Catalog	JdbcCatalogFactory.create(FileIO fileIO, Path warehouse, CatalogContext context)

Uses of Catalog in org.apache.paimon.operation

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

Modifier and Type	Method and Description
static SerializableConsumer<Path>	OrphanFilesClean.createFileCleaner(Catalog catalog, Boolean dryRun)
static List<LocalOrphanFilesClean>	LocalOrphanFilesClean.createOrphanFilesCleans(Catalog catalog, String databaseName, String tableName, long olderThanMillis, SerializableConsumer<Path> fileCleaner, Integer parallelism)
static long	LocalOrphanFilesClean.executeDatabaseOrphanFiles(Catalog catalog, String databaseName, String tableName, long olderThanMillis, SerializableConsumer<Path> fileCleaner, Integer parallelism)

Uses of Catalog in org.apache.paimon.privilege

Classes in org.apache.paimon.privilege that implement Catalog

Modifier and Type	Class and Description
class	PrivilegedCatalog Catalog which supports privilege system.

Methods in org.apache.paimon.privilege that return Catalog

Modifier and Type	Method and Description
static Catalog	PrivilegedCatalog.tryToCreate(Catalog catalog, Options options)

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

Modifier and Type	Method and Description
static Catalog	PrivilegedCatalog.tryToCreate(Catalog catalog, Options options)

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

Constructor and Description
PrivilegedCatalog(Catalog wrapped, PrivilegeManager privilegeManager)

Uses of Catalog in org.apache.paimon.spark

Fields in org.apache.paimon.spark declared as Catalog

Modifier and Type	Field and Description
protected Catalog	SparkCatalog.catalog

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

Modifier and Type	Method and Description
Catalog	SparkCatalog.paimonCatalog()
Catalog	SparkGenericCatalog.paimonCatalog()

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

Methods in org.apache.paimon.spark.catalog that return Catalog

Modifier and Type	Method and Description
Catalog	WithPaimonCatalog.paimonCatalog()

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

Methods in org.apache.paimon.spark.procedure with parameters of type Catalog

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

Uses of Catalog in org.apache.paimon.spark.utils

Methods in org.apache.paimon.spark.utils with parameters of type Catalog

Modifier and Type	Method and Description
static Migrator	TableMigrationUtils.getImporter(String connector, Catalog catalog, String sourceDatabase, String sourceTableName, String targetDatabase, String targetTableName, Integer parallelism, Map<String,String> options)
static List<Migrator>	TableMigrationUtils.getImporters(String connector, Catalog catalog, String sourceDatabase, Integer parallelism, Map<String,String> options)