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

Class MetastorePartitionServiceGrpc.MetastorePartitionServiceBlockingV2Stub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractBlockingStub<MetastorePartitionServiceGrpc.MetastorePartitionServiceBlockingV2Stub>

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

Enclosing class:

MetastorePartitionServiceGrpc

public static final class MetastorePartitionServiceGrpc.MetastorePartitionServiceBlockingV2Stub
extends io.grpc.stub.AbstractBlockingStub<MetastorePartitionServiceGrpc.MetastorePartitionServiceBlockingV2Stub>

A stub to allow clients to do synchronous 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
BatchCreateMetastorePartitionsResponse	batchCreateMetastorePartitions(BatchCreateMetastorePartitionsRequest request)	Adds metastore partitions to a table.
com.google.protobuf.Empty	batchDeleteMetastorePartitions(BatchDeleteMetastorePartitionsRequest request)	Deletes metastore partitions from a table.
BatchUpdateMetastorePartitionsResponse	batchUpdateMetastorePartitions(BatchUpdateMetastorePartitionsRequest request)	Updates metastore partitions in a table.
protected MetastorePartitionServiceGrpc.MetastorePartitionServiceBlockingV2Stub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
ListMetastorePartitionsResponse	listMetastorePartitions(ListMetastorePartitionsRequest request)	Gets metastore partitions from a table.
io.grpc.stub.BlockingClientCall<StreamMetastorePartitionsRequest,StreamMetastorePartitionsResponse>	streamMetastorePartitions()	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.AbstractBlockingStub

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

Specified by:

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

batchCreateMetastorePartitions

public BatchCreateMetastorePartitionsResponse batchCreateMetastorePartitions(BatchCreateMetastorePartitionsRequest request)
                                                                      throws io.grpc.StatusException

 Adds metastore partitions to a table.
 

Throws:

io.grpc.StatusException

batchDeleteMetastorePartitions

public com.google.protobuf.Empty batchDeleteMetastorePartitions(BatchDeleteMetastorePartitionsRequest request)
                                                         throws io.grpc.StatusException

 Deletes metastore partitions from a table.
 

Throws:

io.grpc.StatusException

batchUpdateMetastorePartitions

public BatchUpdateMetastorePartitionsResponse batchUpdateMetastorePartitions(BatchUpdateMetastorePartitionsRequest request)
                                                                      throws io.grpc.StatusException

 Updates metastore partitions in a table.
 

Throws:

io.grpc.StatusException

listMetastorePartitions

public ListMetastorePartitionsResponse listMetastorePartitions(ListMetastorePartitionsRequest request)
                                                        throws io.grpc.StatusException

 Gets metastore partitions from a table.
 

Throws:

io.grpc.StatusException

streamMetastorePartitions

@ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
public io.grpc.stub.BlockingClientCall<StreamMetastorePartitionsRequest,StreamMetastorePartitionsResponse> streamMetastorePartitions()

 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).