alluxio.master.table

Class TableMasterClientServiceHandler

java.lang.Object

alluxio.grpc.table.TableMasterClientServiceGrpc.TableMasterClientServiceImplBase

alluxio.master.table.TableMasterClientServiceHandler

All Implemented Interfaces:

io.grpc.BindableService

public class TableMasterClientServiceHandler
extends TableMasterClientServiceGrpc.TableMasterClientServiceImplBase

This class is a gRPC handler for table master RPCs.

Constructor Summary

Constructors

Constructor and Description
TableMasterClientServiceHandler(TableMaster tableMaster) Creates a new instance of TableMasterClientServiceHandler.

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
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 alluxio.grpc.table.TableMasterClientServiceGrpc.TableMasterClientServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Detail

TableMasterClientServiceHandler

public TableMasterClientServiceHandler(TableMaster tableMaster)

Creates a new instance of TableMasterClientServiceHandler.

Parameters:

tableMaster - the TableMaster the handler uses internally

Method Detail

attachDatabase

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

Description copied from class: TableMasterClientServiceGrpc.TableMasterClientServiceImplBase

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

Overrides:

attachDatabase in class TableMasterClientServiceGrpc.TableMasterClientServiceImplBase

detachDatabase

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

Description copied from class: TableMasterClientServiceGrpc.TableMasterClientServiceImplBase

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

Overrides:

detachDatabase in class TableMasterClientServiceGrpc.TableMasterClientServiceImplBase

getAllDatabases

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

Description copied from class: TableMasterClientServiceGrpc.TableMasterClientServiceImplBase

 Returns all databases in the catalog
 

Overrides:

getAllDatabases in class TableMasterClientServiceGrpc.TableMasterClientServiceImplBase

getAllTables

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

Description copied from class: TableMasterClientServiceGrpc.TableMasterClientServiceImplBase

 Returns all tables in the database
 

Overrides:

getAllTables in class TableMasterClientServiceGrpc.TableMasterClientServiceImplBase

getDatabase

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

Description copied from class: TableMasterClientServiceGrpc.TableMasterClientServiceImplBase

 Gets a database by name from the table master
 

Overrides:

getDatabase in class TableMasterClientServiceGrpc.TableMasterClientServiceImplBase

getTable

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

Description copied from class: TableMasterClientServiceGrpc.TableMasterClientServiceImplBase

 Returns a specific table info
 

Overrides:

getTable in class TableMasterClientServiceGrpc.TableMasterClientServiceImplBase

getTableColumnStatistics

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

Overrides:

getTableColumnStatistics in class TableMasterClientServiceGrpc.TableMasterClientServiceImplBase

getPartitionColumnStatistics

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

Overrides:

getPartitionColumnStatistics in class TableMasterClientServiceGrpc.TableMasterClientServiceImplBase

readTable

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

Overrides:

readTable in class TableMasterClientServiceGrpc.TableMasterClientServiceImplBase

transformTable

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

Overrides:

transformTable in class TableMasterClientServiceGrpc.TableMasterClientServiceImplBase

syncDatabase

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

Description copied from class: TableMasterClientServiceGrpc.TableMasterClientServiceImplBase

 Sync existing database into the catalog
 

Overrides:

syncDatabase in class TableMasterClientServiceGrpc.TableMasterClientServiceImplBase

getTransformJobInfo

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

Description copied from class: TableMasterClientServiceGrpc.TableMasterClientServiceImplBase

 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.
 

Overrides:

getTransformJobInfo in class TableMasterClientServiceGrpc.TableMasterClientServiceImplBase