alluxio.grpc.table

Class TableMasterClientServiceGrpc.TableMasterClientServiceStub

java.lang.Object

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

alluxio.grpc.table.TableMasterClientServiceGrpc.TableMasterClientServiceStub

Enclosing class:

TableMasterClientServiceGrpc

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

 This interface contains table master service endpoints for Alluxio clients.
 

Method Summary

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

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

Specified by:

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

getAllDatabases

public void getAllDatabases(GetAllDatabasesPRequest request,
                            io.grpc.stub.StreamObserver<GetAllDatabasesPResponse> responseObserver)

 Returns all databases in the catalog
 

getAllTables

public void getAllTables(GetAllTablesPRequest request,
                         io.grpc.stub.StreamObserver<GetAllTablesPResponse> responseObserver)

 Returns all tables in the database
 

getDatabase

public void getDatabase(GetDatabasePRequest request,
                        io.grpc.stub.StreamObserver<GetDatabasePResponse> responseObserver)

 Gets a database by name from the table master
 

getTable

public void getTable(GetTablePRequest request,
                     io.grpc.stub.StreamObserver<GetTablePResponse> responseObserver)

 Returns a specific table info
 

attachDatabase

public void attachDatabase(AttachDatabasePRequest request,
                           io.grpc.stub.StreamObserver<AttachDatabasePResponse> responseObserver)

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

detachDatabase

public void detachDatabase(DetachDatabasePRequest request,
                           io.grpc.stub.StreamObserver<DetachDatabasePResponse> responseObserver)

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

syncDatabase

public void syncDatabase(SyncDatabasePRequest request,
                         io.grpc.stub.StreamObserver<SyncDatabasePResponse> responseObserver)

 Sync existing database into the catalog
 

getTableColumnStatistics

public void getTableColumnStatistics(GetTableColumnStatisticsPRequest request,
                                     io.grpc.stub.StreamObserver<GetTableColumnStatisticsPResponse> responseObserver)

getPartitionColumnStatistics

public void getPartitionColumnStatistics(GetPartitionColumnStatisticsPRequest request,
                                         io.grpc.stub.StreamObserver<GetPartitionColumnStatisticsPResponse> responseObserver)

readTable

public void readTable(ReadTablePRequest request,
                      io.grpc.stub.StreamObserver<ReadTablePResponse> responseObserver)

transformTable

public void transformTable(TransformTablePRequest request,
                           io.grpc.stub.StreamObserver<TransformTablePResponse> responseObserver)

getTransformJobInfo

public void getTransformJobInfo(GetTransformJobInfoPRequest request,
                                io.grpc.stub.StreamObserver<GetTransformJobInfoPResponse> responseObserver)

 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.