alluxio.grpc.table

Class TableMasterClientServiceGrpc.TableMasterClientServiceFutureStub

java.lang.Object

io.grpc.stub.AbstractStub<TableMasterClientServiceGrpc.TableMasterClientServiceFutureStub>

alluxio.grpc.table.TableMasterClientServiceGrpc.TableMasterClientServiceFutureStub

Enclosing class:

TableMasterClientServiceGrpc

public static final class TableMasterClientServiceGrpc.TableMasterClientServiceFutureStub
extends io.grpc.stub.AbstractStub<TableMasterClientServiceGrpc.TableMasterClientServiceFutureStub>

 This interface contains table master service endpoints for Alluxio clients.
 

Method Summary

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

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.TableMasterClientServiceFutureStub build(io.grpc.Channel channel,
                                                                                io.grpc.CallOptions callOptions)

Specified by:

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

getAllDatabases

public com.google.common.util.concurrent.ListenableFuture<GetAllDatabasesPResponse> getAllDatabases(GetAllDatabasesPRequest request)

 Returns all databases in the catalog
 

getAllTables

public com.google.common.util.concurrent.ListenableFuture<GetAllTablesPResponse> getAllTables(GetAllTablesPRequest request)

 Returns all tables in the database
 

getDatabase

public com.google.common.util.concurrent.ListenableFuture<GetDatabasePResponse> getDatabase(GetDatabasePRequest request)

 Gets a database by name from the table master
 

getTable

public com.google.common.util.concurrent.ListenableFuture<GetTablePResponse> getTable(GetTablePRequest request)

 Returns a specific table info
 

attachDatabase

public com.google.common.util.concurrent.ListenableFuture<AttachDatabasePResponse> attachDatabase(AttachDatabasePRequest request)

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

detachDatabase

public com.google.common.util.concurrent.ListenableFuture<DetachDatabasePResponse> detachDatabase(DetachDatabasePRequest request)

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

syncDatabase

public com.google.common.util.concurrent.ListenableFuture<SyncDatabasePResponse> syncDatabase(SyncDatabasePRequest request)

 Sync existing database into the catalog
 

getTableColumnStatistics

public com.google.common.util.concurrent.ListenableFuture<GetTableColumnStatisticsPResponse> getTableColumnStatistics(GetTableColumnStatisticsPRequest request)

getPartitionColumnStatistics

public com.google.common.util.concurrent.ListenableFuture<GetPartitionColumnStatisticsPResponse> getPartitionColumnStatistics(GetPartitionColumnStatisticsPRequest request)

readTable

public com.google.common.util.concurrent.ListenableFuture<ReadTablePResponse> readTable(ReadTablePRequest request)

transformTable

public com.google.common.util.concurrent.ListenableFuture<TransformTablePResponse> transformTable(TransformTablePRequest request)

getTransformJobInfo

public com.google.common.util.concurrent.ListenableFuture<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.