Interface MetastorePartitionServiceGrpc.AsyncService (3.9.3)

public static interface MetastorePartitionServiceGrpc.AsyncService

BigQuery Metastore Partition Service API. This service is used for managing metastore partitions in BigQuery metastore. The service supports only batch operations for write.

Methods

batchCreateMetastorePartitions(BatchCreateMetastorePartitionsRequest request, StreamObserver<BatchCreateMetastorePartitionsResponse> responseObserver)

public default void batchCreateMetastorePartitions(BatchCreateMetastorePartitionsRequest request, StreamObserver<BatchCreateMetastorePartitionsResponse> responseObserver)

Adds metastore partitions to a table.

Parameters
Name Description
request BatchCreateMetastorePartitionsRequest
responseObserver io.grpc.stub.StreamObserver<BatchCreateMetastorePartitionsResponse>

batchDeleteMetastorePartitions(BatchDeleteMetastorePartitionsRequest request, StreamObserver<Empty> responseObserver)

public default void batchDeleteMetastorePartitions(BatchDeleteMetastorePartitionsRequest request, StreamObserver<Empty> responseObserver)

Deletes metastore partitions from a table.

Parameters
Name Description
request BatchDeleteMetastorePartitionsRequest
responseObserver io.grpc.stub.StreamObserver<Empty>

batchUpdateMetastorePartitions(BatchUpdateMetastorePartitionsRequest request, StreamObserver<BatchUpdateMetastorePartitionsResponse> responseObserver)

public default void batchUpdateMetastorePartitions(BatchUpdateMetastorePartitionsRequest request, StreamObserver<BatchUpdateMetastorePartitionsResponse> responseObserver)

Updates metastore partitions in a table.

Parameters
Name Description
request BatchUpdateMetastorePartitionsRequest
responseObserver io.grpc.stub.StreamObserver<BatchUpdateMetastorePartitionsResponse>

listMetastorePartitions(ListMetastorePartitionsRequest request, StreamObserver<ListMetastorePartitionsResponse> responseObserver)

public default void listMetastorePartitions(ListMetastorePartitionsRequest request, StreamObserver<ListMetastorePartitionsResponse> responseObserver)

Gets metastore partitions from a table.

Parameters
Name Description
request ListMetastorePartitionsRequest
responseObserver io.grpc.stub.StreamObserver<ListMetastorePartitionsResponse>

streamMetastorePartitions(StreamObserver<StreamMetastorePartitionsResponse> responseObserver)

public default StreamObserver<StreamMetastorePartitionsRequest> streamMetastorePartitions(StreamObserver<StreamMetastorePartitionsResponse> responseObserver)

This is a bi-di streaming rpc method that allows the client to send a stream of partitions and commit all of them atomically at the end. If the commit is successful, the server will return a response and close the stream. If the commit fails (due to duplicate partitions or other reason), the server will close the stream with an error. This method is only available via the gRPC API (not REST).

Parameter
Name Description
responseObserver io.grpc.stub.StreamObserver<StreamMetastorePartitionsResponse>
Returns
Type Description
io.grpc.stub.StreamObserver<StreamMetastorePartitionsRequest>