alluxio.master.table

Interface TableMaster

All Superinterfaces:

Checkpointed, Journaled, JournalEntryIterable, Master, Server<Boolean>

All Known Implementing Classes:

DefaultTableMaster

public interface TableMaster
extends Master

Interface of the table master that manages the table service.

Method Summary

Modifier and Type	Method and Description
SyncStatus	attachDatabase(String udbType, String udbConnectionUri, String udbDbName, String dbName, Map<String,String> configuration, boolean ignoreSyncErrors) Attach an existing database to the catalog.
boolean	detachDatabase(String dbName) Remove an existing database in the catalog.
List<String>	getAllDatabases() Get a listing of all databases.
List<String>	getAllTables(String databaseName) Get a listing of all tables in a database.
List<TransformJobInfo>	getAllTransformJobInfo()
Database	getDatabase(String dbName) Gets a database object.
Map<String,ColumnStatisticsList>	getPartitionColumnStatistics(String dbName, String tableName, List<String> partNamesList, List<String> colNamesList) Get statistics on the partitions.
Table	getTable(String databaseName, String tableName) Get a table.
List<ColumnStatisticsInfo>	getTableColumnStatistics(String databaseName, String tableName, List<String> colNames) Get statistics on the table.
TransformJobInfo	getTransformJobInfo(long jobId)
List<Partition>	readTable(String dbName, String tableName, Constraint constraint) Returns metadata for reading a table given constraints.
SyncStatus	syncDatabase(String dbName) Syncs a database.
long	transformTable(String dbName, String tableName, String definition) Transforms a table to a new table.

Methods inherited from interface alluxio.master.Master

createJournalContext, getMasterContext, getStandbyServices

Methods inherited from interface alluxio.master.journal.Journaled

applyAndJournal, processJournalEntry, resetState, restoreFromCheckpoint, writeToCheckpoint

Methods inherited from interface alluxio.master.journal.checkpoint.Checkpointed

getCheckpointName

Methods inherited from interface alluxio.master.journal.JournalEntryIterable

getJournalEntryIterator

Methods inherited from interface alluxio.Server

close, getDependencies, getName, getServices, start, stop

Method Detail

attachDatabase

SyncStatus attachDatabase(String udbType,
                          String udbConnectionUri,
                          String udbDbName,
                          String dbName,
                          Map<String,String> configuration,
                          boolean ignoreSyncErrors)
                   throws IOException

Attach an existing database to the catalog.

Parameters:

udbType - the database type

udbConnectionUri - the udb connection uri

udbDbName - the database name in the udb

dbName - the database name in Alluxio

configuration - the configuration

ignoreSyncErrors - if true, will ignore sync errors during the attach

Returns:

the sync status for the attach

Throws:

IOException

detachDatabase

boolean detachDatabase(String dbName)
                throws IOException

Remove an existing database in the catalog.

Parameters:

dbName - the database name to remove

Returns:

true if deletion is successful

Throws:

IOException

getAllDatabases

List<String> getAllDatabases()
                      throws IOException

Get a listing of all databases.

Returns:

a list of database

Throws:

IOException

getAllTables

List<String> getAllTables(String databaseName)
                   throws IOException

Get a listing of all tables in a database.

Parameters:

databaseName - database name

Returns:

a list of tables

Throws:

IOException

getDatabase

Database getDatabase(String dbName)
              throws IOException

Gets a database object.

Parameters:

dbName - the database name

Returns:

a database object

Throws:

IOException

getTable

Table getTable(String databaseName,
               String tableName)
        throws IOException

Get a table.

Parameters:

databaseName - database name

tableName - table name

Returns:

a Table object

Throws:

IOException

getTableColumnStatistics

List<ColumnStatisticsInfo> getTableColumnStatistics(String databaseName,
                                                    String tableName,
                                                    List<String> colNames)
                                             throws IOException

Get statistics on the table.

Parameters:

databaseName - database name

tableName - table name

colNames - column names

Returns:

a list of column statistics info

Throws:

IOException

readTable

List<Partition> readTable(String dbName,
                          String tableName,
                          Constraint constraint)
                   throws IOException

Returns metadata for reading a table given constraints.

Parameters:

dbName - database name

tableName - table name

constraint - constraint

Returns:

a list of partition information

Throws:

IOException

getPartitionColumnStatistics

Map<String,ColumnStatisticsList> getPartitionColumnStatistics(String dbName,
                                                              String tableName,
                                                              List<String> partNamesList,
                                                              List<String> colNamesList)
                                                       throws IOException

Get statistics on the partitions.

Parameters:

dbName - database name

tableName - table name

partNamesList - partition names

colNamesList - column names

Returns:

a map mapping partition names to a list of column statistics info

Throws:

IOException

transformTable

long transformTable(String dbName,
                    String tableName,
                    String definition)
             throws IOException

Transforms a table to a new table.

Parameters:

dbName - the database name

tableName - the table name

definition - the transformation definition

Returns:

the job ID

Throws:

IOException

getTransformJobInfo

TransformJobInfo getTransformJobInfo(long jobId)
                              throws IOException

Parameters:

jobId - the job ID

Returns:

the information for the transformation job

Throws:

IOException

getAllTransformJobInfo

List<TransformJobInfo> getAllTransformJobInfo()
                                       throws IOException

Returns:

a list of information for all the transformation jobs

Throws:

IOException

syncDatabase

SyncStatus syncDatabase(String dbName)
                 throws IOException

Syncs a database.

Parameters:

dbName - the database name

Returns:

the resulting sync status

Throws:

IOException