public static final class HiveMetastoreServiceGrpc.HiveMetastoreServiceBlockingV2Stub extends AbstractBlockingStub<HiveMetastoreServiceGrpc.HiveMetastoreServiceBlockingV2Stub>
A stub to allow clients to do synchronous rpc calls to service HiveMetastoreService.
Hive Metastore Service is a biglake service that allows users to manage
their external Hive catalogs. Full API compatibility with OSS Hive Metastore
APIs is not supported. The methods match the Hive Metastore API spec mostly
except for a few exceptions.
These include listing resources with pattern,
environment context which are combined in a single List API, return of
ListResponse object instead of a list of resources, transactions, locks, etc.
The BigLake Hive Metastore API defines the following resources:
- A collection of Google Cloud projects:
/projects/*
- Each project has a collection of catalogs:
/catalogs/*
- Each catalog has a collection of databases:
/databases/*
- Each database has a collection of tables:
/tables/*
Inheritance
java.lang.Object >
io.grpc.stub.AbstractStub >
io.grpc.stub.AbstractBlockingStub >
HiveMetastoreServiceGrpc.HiveMetastoreServiceBlockingV2Stub
Inherited Members
io.grpc.stub.AbstractBlockingStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel)
io.grpc.stub.AbstractBlockingStub.<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(java.time.Duration)
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()
Methods
public BatchCreatePartitionsResponse batchCreatePartitions(BatchCreatePartitionsRequest request)
Adds partitions to a table.
| Exceptions |
| Type |
Description |
io.grpc.StatusException |
|
public Empty batchDeletePartitions(BatchDeletePartitionsRequest request)
Deletes partitions from a table.
| Returns |
| Type |
Description |
Empty |
|
| Exceptions |
| Type |
Description |
io.grpc.StatusException |
|
public BatchUpdatePartitionsResponse batchUpdatePartitions(BatchUpdatePartitionsRequest request)
Updates partitions in a table.
| Exceptions |
| Type |
Description |
io.grpc.StatusException |
|
protected HiveMetastoreServiceGrpc.HiveMetastoreServiceBlockingV2Stub build(Channel channel, CallOptions callOptions)
| Parameters |
| Name |
Description |
channel |
io.grpc.Channel
|
callOptions |
io.grpc.CallOptions
|
Overrides
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)
public HiveCatalog createHiveCatalog(CreateHiveCatalogRequest request)
Creates a new hive catalog.
| Exceptions |
| Type |
Description |
io.grpc.StatusException |
|
public HiveDatabase createHiveDatabase(CreateHiveDatabaseRequest request)
| Exceptions |
| Type |
Description |
io.grpc.StatusException |
|
public HiveTable createHiveTable(CreateHiveTableRequest request)
Creates a new hive table.
| Exceptions |
| Type |
Description |
io.grpc.StatusException |
|
public Empty deleteHiveCatalog(DeleteHiveCatalogRequest request)
Deletes an existing catalog specified by the catalog ID. Delete will fail
if the catalog is not empty.
| Returns |
| Type |
Description |
Empty |
|
| Exceptions |
| Type |
Description |
io.grpc.StatusException |
|
public Empty deleteHiveDatabase(DeleteHiveDatabaseRequest request)
Deletes an existing database specified by the database name.
| Returns |
| Type |
Description |
Empty |
|
| Exceptions |
| Type |
Description |
io.grpc.StatusException |
|
public Empty deleteHiveTable(DeleteHiveTableRequest request)
Deletes an existing table specified by the table name.
| Returns |
| Type |
Description |
Empty |
|
| Exceptions |
| Type |
Description |
io.grpc.StatusException |
|
public HiveCatalog getHiveCatalog(GetHiveCatalogRequest request)
Gets the catalog specified by the resource name.
| Exceptions |
| Type |
Description |
io.grpc.StatusException |
|
public HiveDatabase getHiveDatabase(GetHiveDatabaseRequest request)
Gets the database specified by the resource name.
| Exceptions |
| Type |
Description |
io.grpc.StatusException |
|
public HiveTable getHiveTable(GetHiveTableRequest request)
Gets the table specified by the resource name.
| Exceptions |
| Type |
Description |
io.grpc.StatusException |
|
public ListHiveCatalogsResponse listHiveCatalogs(ListHiveCatalogsRequest request)
List all catalogs in a specified project.
| Exceptions |
| Type |
Description |
io.grpc.StatusException |
|
public ListHiveDatabasesResponse listHiveDatabases(ListHiveDatabasesRequest request)
List all databases in a specified catalog.
| Exceptions |
| Type |
Description |
io.grpc.StatusException |
|
public ListHiveTablesResponse listHiveTables(ListHiveTablesRequest request)
List all hive tables in a specified project under the hive catalog and
database.
| Exceptions |
| Type |
Description |
io.grpc.StatusException |
|
public BlockingClientCall<?,ListPartitionsResponse> listPartitions(ListPartitionsRequest request)
Streams list of partitions from a table.
public HiveCatalog updateHiveCatalog(UpdateHiveCatalogRequest request)
Updates an existing catalog.
| Exceptions |
| Type |
Description |
io.grpc.StatusException |
|
public HiveDatabase updateHiveDatabase(UpdateHiveDatabaseRequest request)
Updates an existing database specified by the database name.
| Exceptions |
| Type |
Description |
io.grpc.StatusException |
|
public HiveTable updateHiveTable(UpdateHiveTableRequest request)
Updates an existing table specified by the table name.
| Exceptions |
| Type |
Description |
io.grpc.StatusException |
|