alluxio.client.table

Interface TableMasterClient

All Superinterfaces:

AutoCloseable, Client, Closeable

All Known Implementing Classes:

RetryHandlingTableMasterClient

@ThreadSafe
public interface TableMasterClient
extends Client

A client to use for interacting with a table master.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	TableMasterClient.Factory Factory for TableMasterClient.

Method Summary

Modifier and Type	Method and Description
SyncStatus	attachDatabase(String udbType, String udbConnectionUri, String udbDbName, String dbName, Map<String,String> configuration, boolean ignoreSyncErrors) Attaches an existing database.
boolean	detachDatabase(String dbName) Detaches an existing database in the catalog master.
List<String>	getAllDatabases() Get a list of all database names.
List<String>	getAllTables(String databaseName) Get a list of all table names.
List<TransformJobInfo>	getAllTransformJobInfo()
Database	getDatabase(String databaseName) Get database metadata.
Map<String,List<ColumnStatisticsInfo>>	getPartitionColumnStatistics(String databaseName, String tableName, List<String> partitionNames, List<String> columnNames) Get column statistics for selected partition and column.
List<String>	getPartitionNames(String databaseName, String tableName) Get partition names with given database name and table name.
TableInfo	getTable(String databaseName, String tableName) Get table metadata.
List<ColumnStatisticsInfo>	getTableColumnStatistics(String databaseName, String tableName, List<String> columnNames) Get table column statistics with given database name, table name and list of column names.
TransformJobInfo	getTransformJobInfo(long jobId)
List<Partition>	readTable(String databaseName, String tableName, Constraint constraint) Returns metadata for reading a table given constraints.
SyncStatus	syncDatabase(String dbName) Syncs an existing database in the catalog master.
long	transformTable(String dbName, String tableName, String definition) Transforms a table.

Methods inherited from interface alluxio.Client

connect, disconnect, getAddress, getConfAddress, isClosed, isConnected

Methods inherited from interface java.io.Closeable

close

Method Detail

getAllDatabases

List<String> getAllDatabases()
                      throws AlluxioStatusException

Get a list of all database names.

Returns:

list of database names

Throws:

AlluxioStatusException

getDatabase

Database getDatabase(String databaseName)
              throws AlluxioStatusException

Get database metadata.

Parameters:

databaseName - database name

Returns:

database metadata

Throws:

AlluxioStatusException

getAllTables

List<String> getAllTables(String databaseName)
                   throws AlluxioStatusException

Get a list of all table names.

Parameters:

databaseName - database name

Returns:

list of table names

Throws:

AlluxioStatusException

getTable

TableInfo getTable(String databaseName,
                   String tableName)
            throws AlluxioStatusException

Get table metadata.

Parameters:

databaseName - database name

tableName - table name

Returns:

table metadata

Throws:

AlluxioStatusException

attachDatabase

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

Attaches an existing database.

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 map

ignoreSyncErrors - will ignore sync errors if true

Returns:

the sync status for the attach

Throws:

AlluxioStatusException

detachDatabase

boolean detachDatabase(String dbName)
                throws AlluxioStatusException

Detaches an existing database in the catalog master.

Parameters:

dbName - database name

Returns:

true if database created successfully

Throws:

AlluxioStatusException

syncDatabase

SyncStatus syncDatabase(String dbName)
                 throws AlluxioStatusException

Syncs an existing database in the catalog master.

Parameters:

dbName - database name

Returns:

the sync status

Throws:

AlluxioStatusException

readTable

List<Partition> readTable(String databaseName,
                          String tableName,
                          Constraint constraint)
                   throws AlluxioStatusException

Returns metadata for reading a table given constraints.

Parameters:

databaseName - database name

tableName - table name

constraint - constraint on the columns

Returns:

list of partitions

Throws:

AlluxioStatusException

getTableColumnStatistics

List<ColumnStatisticsInfo> getTableColumnStatistics(String databaseName,
                                                    String tableName,
                                                    List<String> columnNames)
                                             throws AlluxioStatusException

Get table column statistics with given database name, table name and list of column names.

Parameters:

databaseName - database name

tableName - table name

columnNames - column names

Returns:

list of column statistics

Throws:

AlluxioStatusException

getPartitionNames

List<String> getPartitionNames(String databaseName,
                               String tableName)
                        throws AlluxioStatusException

Get partition names with given database name and table name.

Parameters:

databaseName - database name

tableName - table name

Returns:

list of partition names

Throws:

AlluxioStatusException

getPartitionColumnStatistics

Map<String,List<ColumnStatisticsInfo>> getPartitionColumnStatistics(String databaseName,
                                                                    String tableName,
                                                                    List<String> partitionNames,
                                                                    List<String> columnNames)
                                                             throws AlluxioStatusException

Get column statistics for selected partition and column.

Parameters:

databaseName - database name

tableName - table name

partitionNames - partition names

columnNames - column names

Returns:

Map>

Throws:

AlluxioStatusException

transformTable

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

Transforms a table.

Parameters:

dbName - the database name

tableName - the table name

definition - the transformation definition

Returns:

job ID which can be used to poll the job status from job service

Throws:

AlluxioStatusException

getTransformJobInfo

TransformJobInfo getTransformJobInfo(long jobId)
                              throws AlluxioStatusException

Parameters:

jobId - the transformation job's ID

Returns:

the job info

Throws:

AlluxioStatusException

getAllTransformJobInfo

List<TransformJobInfo> getAllTransformJobInfo()
                                       throws AlluxioStatusException

Returns:

a list of information for all transformation jobs

Throws:

AlluxioStatusException