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 Table	createSystemTable(Identifier identifier, Table originTable)
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 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 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)

createSystemTable

public static Table createSystemTable(Identifier identifier,
                                      Table originTable)
                               throws Catalog.TableNotExistException

Throws:

Catalog.TableNotExistException

listPartitionsFromFileSystem

public static List<Partition> listPartitionsFromFileSystem(Table table)