org.apache.paimon.catalog

Class CatalogUtils

java.lang.Object

org.apache.paimon.catalog.CatalogUtils

public class CatalogUtils
extends Object

Utils for Catalog.

Constructor Summary

Constructors

Constructor and Description
CatalogUtils()

Method Summary

Modifier and Type	Method and Description
static void	checkNotBranch(Identifier identifier, String method)
static void	checkNotSystemDatabase(String database) Validate database cannot be a system database.
static void	checkNotSystemTable(Identifier identifier, String method)
static String	database(Path path)
static String	database(String path)
static boolean	isSystemDatabase(String database)
static boolean	isTableInSystemDatabase(Identifier identifier)
static List<Partition>	listPartitionsFromFileSystem(Table table)
static Table	loadTable(Catalog catalog, Identifier identifier, java.util.function.Function<Path,FileIO> dataFileIO, java.util.function.Function<Path,FileIO> objectFileIO, TableMetadata.Loader metadataLoader, SnapshotCommit.Factory commitFactory) Load table from Catalog, this table can be: 1.
static Path	path(String warehouse, String database, String table)
static String	stringifyPath(String warehouse, String database, String table)
static String	table(Path path)
static String	table(String path)
static Map<String,String>	tableDefaultOptions(Map<String,String> options)
static void	validateAutoCreateClose(Map<String,String> options)
static String	warehouse(String path)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CatalogUtils

public CatalogUtils()

Method Detail

path

public static Path path(String warehouse,
                        String database,
                        String table)

stringifyPath

public static String stringifyPath(String warehouse,
                                   String database,
                                   String table)

warehouse

public static String warehouse(String path)

database

public static String database(Path path)

database

public static String database(String path)

table

public static String table(Path path)

table

public static String table(String path)

tableDefaultOptions

public static Map<String,String> tableDefaultOptions(Map<String,String> options)

isSystemDatabase

public static boolean isSystemDatabase(String database)

checkNotSystemDatabase

public static void checkNotSystemDatabase(String database)

Validate database cannot be a system database.

isTableInSystemDatabase

public static boolean isTableInSystemDatabase(Identifier identifier)

checkNotSystemTable

public static void checkNotSystemTable(Identifier identifier,
                                       String method)

checkNotBranch

public static void checkNotBranch(Identifier identifier,
                                  String method)

validateAutoCreateClose

public static void validateAutoCreateClose(Map<String,String> options)

listPartitionsFromFileSystem

public static List<Partition> listPartitionsFromFileSystem(Table table)

loadTable

public static Table loadTable(Catalog catalog,
                              Identifier identifier,
                              java.util.function.Function<Path,FileIO> dataFileIO,
                              java.util.function.Function<Path,FileIO> objectFileIO,
                              TableMetadata.Loader metadataLoader,
                              SnapshotCommit.Factory commitFactory)
                       throws Catalog.TableNotExistException

Load table from Catalog, this table can be:

• 1. Global System table: contains the statistical information of all the tables exists.
• 2. Format table: refers to a directory that contains multiple files of the same format.
• 3. Data table: Normal FileStoreTable, primary key table or append table.
• 4. Object table: provides metadata indexes for unstructured data in the location.
• 5. System table: wraps Data table or Object table, such as the snapshots created.

Throws:

Catalog.TableNotExistException