Package com.google.cloud.bigquery.storage.v1beta

Class MetastorePartitionServiceGrpc.MetastorePartitionServiceStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractAsyncStub<MetastorePartitionServiceGrpc.MetastorePartitionServiceStub>

com.google.cloud.bigquery.storage.v1beta.MetastorePartitionServiceGrpc.MetastorePartitionServiceStub

Enclosing class:

MetastorePartitionServiceGrpc

public static final class MetastorePartitionServiceGrpc.MetastorePartitionServiceStub
extends io.grpc.stub.AbstractAsyncStub<MetastorePartitionServiceGrpc.MetastorePartitionServiceStub>

A stub to allow clients to do asynchronous rpc calls to service MetastorePartitionService.

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

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

Modifier and Type	Method	Description
void	batchCreateMetastorePartitions(BatchCreateMetastorePartitionsRequest request, io.grpc.stub.StreamObserver<BatchCreateMetastorePartitionsResponse> responseObserver)	Adds metastore partitions to a table.
void	batchDeleteMetastorePartitions(BatchDeleteMetastorePartitionsRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)	Deletes metastore partitions from a table.
void	batchUpdateMetastorePartitions(BatchUpdateMetastorePartitionsRequest request, io.grpc.stub.StreamObserver<BatchUpdateMetastorePartitionsResponse> responseObserver)	Updates metastore partitions in a table.
protected MetastorePartitionServiceGrpc.MetastorePartitionServiceStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
void	listMetastorePartitions(ListMetastorePartitionsRequest request, io.grpc.stub.StreamObserver<ListMetastorePartitionsResponse> responseObserver)	Gets metastore partitions from a table.
io.grpc.stub.StreamObserver<StreamMetastorePartitionsRequest>	streamMetastorePartitions(io.grpc.stub.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.

Methods inherited from class io.grpc.stub.AbstractAsyncStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady

Methods inherited from class java.lang.Object

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

Method Details

build

protected MetastorePartitionServiceGrpc.MetastorePartitionServiceStub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<MetastorePartitionServiceGrpc.MetastorePartitionServiceStub>

batchCreateMetastorePartitions

public void batchCreateMetastorePartitions(BatchCreateMetastorePartitionsRequest request,
 io.grpc.stub.StreamObserver<BatchCreateMetastorePartitionsResponse> responseObserver)

 Adds metastore partitions to a table.
 

batchDeleteMetastorePartitions

public void batchDeleteMetastorePartitions(BatchDeleteMetastorePartitionsRequest request,
 io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

 Deletes metastore partitions from a table.
 

batchUpdateMetastorePartitions

public void batchUpdateMetastorePartitions(BatchUpdateMetastorePartitionsRequest request,
 io.grpc.stub.StreamObserver<BatchUpdateMetastorePartitionsResponse> responseObserver)

 Updates metastore partitions in a table.
 

listMetastorePartitions

public void listMetastorePartitions(ListMetastorePartitionsRequest request,
 io.grpc.stub.StreamObserver<ListMetastorePartitionsResponse> responseObserver)

 Gets metastore partitions from a table.
 

streamMetastorePartitions

public io.grpc.stub.StreamObserver<StreamMetastorePartitionsRequest> streamMetastorePartitions(io.grpc.stub.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).