public class FileSystemCatalog extends AbstractCatalog
FileIO
.Catalog.ColumnAlreadyExistException, Catalog.ColumnNotExistException, Catalog.DatabaseAlreadyExistException, Catalog.DatabaseNotEmptyException, Catalog.DatabaseNotExistException, Catalog.Loader, Catalog.PartitionNotExistException, Catalog.ProcessSystemDatabaseException, Catalog.TableAlreadyExistException, Catalog.TableNotExistException, Catalog.ViewAlreadyExistException, Catalog.ViewNotExistException
catalogOptions, fileIO, lineageMetaFactory, tableDefaultOptions
COMMENT_PROP, DB_LOCATION_PROP, DB_SUFFIX, DEFAULT_DATABASE, HIVE_LAST_UPDATE_TIME_PROP, LAST_UPDATE_TIME_PROP, NUM_FILES_PROP, NUM_ROWS_PROP, SYSTEM_BRANCH_PREFIX, SYSTEM_DATABASE_NAME, SYSTEM_TABLE_SPLITTER, TABLE_DEFAULT_OPTION_PREFIX, TOTAL_SIZE_PROP
Constructor and Description |
---|
FileSystemCatalog(FileIO fileIO,
Path warehouse) |
FileSystemCatalog(FileIO fileIO,
Path warehouse,
Options options) |
Modifier and Type | Method and Description |
---|---|
boolean |
allowUpperCase()
Return a boolean that indicates whether this catalog allow upper case.
|
protected void |
alterTableImpl(Identifier identifier,
List<SchemaChange> changes) |
void |
close() |
protected void |
createDatabaseImpl(String name,
Map<String,String> properties) |
void |
createTableImpl(Identifier identifier,
Schema schema) |
protected void |
dropDatabaseImpl(String name) |
protected void |
dropTableImpl(Identifier identifier) |
Database |
getDatabaseImpl(String name) |
TableSchema |
getDataTableSchema(Identifier identifier) |
List<String> |
listDatabases()
Get the names of all databases in this catalog.
|
protected List<String> |
listTablesImpl(String databaseName) |
void |
renameTableImpl(Identifier fromTable,
Identifier toTable) |
protected static <T> T |
uncheck(Callable<T> callable) |
String |
warehouse()
Warehouse root path containing all database directories in this catalog.
|
allTablePaths, alterTable, assertMainBranch, checkNotBranch, checkNotSystemDatabase, checkNotSystemTable, createDatabase, createFormatTable, createPartition, createTable, defaultLockFactory, dropDatabase, dropPartition, dropTable, fileIO, getDatabase, getDataOrFormatTable, getTable, getTableLocation, isSpecifiedSystemTable, isSystemDatabase, isTableInSystemDatabase, listDatabasesInFileSystem, listPartitions, listTables, listTablesInFileSystem, lockContext, lockEnabled, lockFactory, metastoreClientFactory, newDatabasePath, newDatabasePath, newTableLocation, options, renameTable, tableExistsInFileSystem, tableSchemaInFileSystem, validateFieldNameCaseInsensitive, validateIdentifierNameCaseInsensitive
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
alterTable, createDatabase, createView, dropView, getView, invalidateTable, listViews, renameView, repairCatalog, repairDatabase, repairTable, tableDefaultOptions, validateCaseInsensitive, validateCaseInsensitive
public List<String> listDatabases()
Catalog
protected void createDatabaseImpl(String name, Map<String,String> properties)
createDatabaseImpl
in class AbstractCatalog
public Database getDatabaseImpl(String name) throws Catalog.DatabaseNotExistException
getDatabaseImpl
in class AbstractCatalog
Catalog.DatabaseNotExistException
protected void dropDatabaseImpl(String name)
dropDatabaseImpl
in class AbstractCatalog
protected List<String> listTablesImpl(String databaseName)
listTablesImpl
in class AbstractCatalog
public TableSchema getDataTableSchema(Identifier identifier) throws Catalog.TableNotExistException
getDataTableSchema
in class AbstractCatalog
Catalog.TableNotExistException
protected void dropTableImpl(Identifier identifier)
dropTableImpl
in class AbstractCatalog
public void createTableImpl(Identifier identifier, Schema schema)
createTableImpl
in class AbstractCatalog
public void renameTableImpl(Identifier fromTable, Identifier toTable)
renameTableImpl
in class AbstractCatalog
protected void alterTableImpl(Identifier identifier, List<SchemaChange> changes) throws Catalog.TableNotExistException, Catalog.ColumnAlreadyExistException, Catalog.ColumnNotExistException
alterTableImpl
in class AbstractCatalog
Catalog.TableNotExistException
Catalog.ColumnAlreadyExistException
Catalog.ColumnNotExistException
protected static <T> T uncheck(Callable<T> callable)
public String warehouse()
Catalog
public boolean allowUpperCase()
Catalog
allowUpperCase
in interface Catalog
allowUpperCase
in class AbstractCatalog
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.