alluxio.grpc.table

Class TableMasterClientServiceGrpc.TableMasterClientServiceImplBase

java.lang.Object

alluxio.grpc.table.TableMasterClientServiceGrpc.TableMasterClientServiceImplBase

All Implemented Interfaces:

io.grpc.BindableService

Direct Known Subclasses:

TableMasterClientServiceHandler

Enclosing class:

TableMasterClientServiceGrpc

public abstract static class TableMasterClientServiceGrpc.TableMasterClientServiceImplBase
extends Object
implements io.grpc.BindableService

 This interface contains table master service endpoints for Alluxio clients.
 

Constructor Summary

Constructors

Constructor and Description
TableMasterClientServiceImplBase()

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
io.grpc.ServerServiceDefinition	bindService()
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 java.lang.Object

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

Constructor Detail

TableMasterClientServiceImplBase

public TableMasterClientServiceImplBase()

Method Detail

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.
 

bindService

public final io.grpc.ServerServiceDefinition bindService()

Specified by:

bindService in interface io.grpc.BindableService