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

Interface MetastorePartitionServiceGrpc.AsyncService

All Known Implementing Classes:
MetastorePartitionServiceGrpc.MetastorePartitionServiceImplBase
Enclosing class:
MetastorePartitionServiceGrpc
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.

  • Method Details

    • batchCreateMetastorePartitions

      default void batchCreateMetastorePartitions(BatchCreateMetastorePartitionsRequest request, io.grpc.stub.StreamObserver<BatchCreateMetastorePartitionsResponse> responseObserver)
       Adds metastore partitions to a table.

    • batchDeleteMetastorePartitions

      default void batchDeleteMetastorePartitions(BatchDeleteMetastorePartitionsRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
       Deletes metastore partitions from a table.

    • batchUpdateMetastorePartitions

      default void batchUpdateMetastorePartitions(BatchUpdateMetastorePartitionsRequest request, io.grpc.stub.StreamObserver<BatchUpdateMetastorePartitionsResponse> responseObserver)
       Updates metastore partitions in a table.

    • listMetastorePartitions

      default void listMetastorePartitions(ListMetastorePartitionsRequest request, io.grpc.stub.StreamObserver<ListMetastorePartitionsResponse> responseObserver)
       Gets metastore partitions from a table.

    • streamMetastorePartitions

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