alluxio.grpc.table

Class TableMasterClientServiceGrpc.TableMasterClientServiceBlockingStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractBlockingStub<TableMasterClientServiceGrpc.TableMasterClientServiceBlockingStub>

alluxio.grpc.table.TableMasterClientServiceGrpc.TableMasterClientServiceBlockingStub

Enclosing class:

TableMasterClientServiceGrpc

public static final class TableMasterClientServiceGrpc.TableMasterClientServiceBlockingStub
extends io.grpc.stub.AbstractBlockingStub<TableMasterClientServiceGrpc.TableMasterClientServiceBlockingStub>

 This interface contains table master service endpoints for Alluxio clients.
 

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

Modifier and Type	Method and Description
AttachDatabasePResponse	attachDatabase(AttachDatabasePRequest request) Attach an existing database into the catalog as a new database name
protected TableMasterClientServiceGrpc.TableMasterClientServiceBlockingStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
DetachDatabasePResponse	detachDatabase(DetachDatabasePRequest request) Detach existing database into the catalog, removing any metadata about the table
GetAllDatabasesPResponse	getAllDatabases(GetAllDatabasesPRequest request) Returns all databases in the catalog
GetAllTablesPResponse	getAllTables(GetAllTablesPRequest request) Returns all tables in the database
GetDatabasePResponse	getDatabase(GetDatabasePRequest request) Gets a database by name from the table master
GetPartitionColumnStatisticsPResponse	getPartitionColumnStatistics(GetPartitionColumnStatisticsPRequest request)
GetTablePResponse	getTable(GetTablePRequest request) Returns a specific table info
GetTableColumnStatisticsPResponse	getTableColumnStatistics(GetTableColumnStatisticsPRequest request)
GetTransformJobInfoPResponse	getTransformJobInfo(GetTransformJobInfoPRequest request) Gets information of transformation jobs.
ReadTablePResponse	readTable(ReadTablePRequest request)
SyncDatabasePResponse	syncDatabase(SyncDatabasePRequest request) Sync existing database into the catalog
TransformTablePResponse	transformTable(TransformTablePRequest request)

Methods inherited from class io.grpc.stub.AbstractBlockingStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReady

Methods inherited from class java.lang.Object

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

Method Detail

build

protected TableMasterClientServiceGrpc.TableMasterClientServiceBlockingStub build(io.grpc.Channel channel,
                                                                                  io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<TableMasterClientServiceGrpc.TableMasterClientServiceBlockingStub>

getAllDatabases

public GetAllDatabasesPResponse getAllDatabases(GetAllDatabasesPRequest request)

 Returns all databases in the catalog
 

getAllTables

public GetAllTablesPResponse getAllTables(GetAllTablesPRequest request)

 Returns all tables in the database
 

getDatabase

public GetDatabasePResponse getDatabase(GetDatabasePRequest request)

 Gets a database by name from the table master
 

getTable

public GetTablePResponse getTable(GetTablePRequest request)

 Returns a specific table info
 

attachDatabase

public AttachDatabasePResponse attachDatabase(AttachDatabasePRequest request)

 Attach an existing database into the catalog as a new database name
 

detachDatabase

public DetachDatabasePResponse detachDatabase(DetachDatabasePRequest request)

 Detach existing database into the catalog, removing any metadata about the table
 

syncDatabase

public SyncDatabasePResponse syncDatabase(SyncDatabasePRequest request)

 Sync existing database into the catalog
 

getTableColumnStatistics

public GetTableColumnStatisticsPResponse getTableColumnStatistics(GetTableColumnStatisticsPRequest request)

getPartitionColumnStatistics

public GetPartitionColumnStatisticsPResponse getPartitionColumnStatistics(GetPartitionColumnStatisticsPRequest request)

readTable

public ReadTablePResponse readTable(ReadTablePRequest request)

transformTable

public TransformTablePResponse transformTable(TransformTablePRequest request)

getTransformJobInfo

public GetTransformJobInfoPResponse getTransformJobInfo(GetTransformJobInfoPRequest request)

 Gets information of transformation jobs.
 If the job ID exists in the request, the information for that job is returned;
 Otherwise, information of all the jobs kept in table master will be returned.