Class MetastorePartitionServiceGrpc.MetastorePartitionServiceStub (3.10.3)

public static final class MetastorePartitionServiceGrpc.MetastorePartitionServiceStub extends 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.

Inheritance

java.lang.Object > io.grpc.stub.AbstractStub > io.grpc.stub.AbstractAsyncStub > MetastorePartitionServiceGrpc.MetastorePartitionServiceStub

Inherited Members

io.grpc.stub.AbstractAsyncStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel)

io.grpc.stub.AbstractAsyncStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel,io.grpc.CallOptions)

io.grpc.stub.AbstractStub.<T>withOption(io.grpc.CallOptions.Key<T>,T)

io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)

io.grpc.stub.AbstractStub.getCallOptions()

io.grpc.stub.AbstractStub.getChannel()

io.grpc.stub.AbstractStub.withCallCredentials(io.grpc.CallCredentials)

io.grpc.stub.AbstractStub.withChannel(io.grpc.Channel)

io.grpc.stub.AbstractStub.withCompression(java.lang.String)

io.grpc.stub.AbstractStub.withDeadline(io.grpc.Deadline)

io.grpc.stub.AbstractStub.withDeadlineAfter(long,java.util.concurrent.TimeUnit)

io.grpc.stub.AbstractStub.withExecutor(java.util.concurrent.Executor)

io.grpc.stub.AbstractStub.withInterceptors(io.grpc.ClientInterceptor...)

io.grpc.stub.AbstractStub.withMaxInboundMessageSize(int)

io.grpc.stub.AbstractStub.withMaxOutboundMessageSize(int)

io.grpc.stub.AbstractStub.withOnReadyThreshold(int)

io.grpc.stub.AbstractStub.withWaitForReady()

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Methods

batchCreateMetastorePartitions(BatchCreateMetastorePartitionsRequest request, StreamObserver<BatchCreateMetastorePartitionsResponse> responseObserver)

public 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 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 void batchUpdateMetastorePartitions(BatchUpdateMetastorePartitionsRequest request, StreamObserver<BatchUpdateMetastorePartitionsResponse> responseObserver)

Updates metastore partitions in a table.

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

build(Channel channel, CallOptions callOptions)

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

Parameters
Name	Description
`channel`	`io.grpc.Channel`
`callOptions`	`io.grpc.CallOptions`

Returns
Type	Description
`MetastorePartitionServiceGrpc.MetastorePartitionServiceStub`

Overrides

io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)

listMetastorePartitions(ListMetastorePartitionsRequest request, StreamObserver<ListMetastorePartitionsResponse> responseObserver)

public 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 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>`