Interface HiveMetastoreServiceGrpc.AsyncService (0.76.0) 

public static interface HiveMetastoreServiceGrpc.AsyncService

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/*

Methods

batchCreatePartitions(BatchCreatePartitionsRequest request, StreamObserver<BatchCreatePartitionsResponse> responseObserver)

public default void batchCreatePartitions(BatchCreatePartitionsRequest request, StreamObserver<BatchCreatePartitionsResponse> responseObserver)

Adds partitions to a table.

Parameters
Name Description
request BatchCreatePartitionsRequest
responseObserver io.grpc.stub.StreamObserver<BatchCreatePartitionsResponse>

batchDeletePartitions(BatchDeletePartitionsRequest request, StreamObserver<Empty> responseObserver)

public default void batchDeletePartitions(BatchDeletePartitionsRequest request, StreamObserver<Empty> responseObserver)

Deletes partitions from a table.

Parameters
Name Description
request BatchDeletePartitionsRequest
responseObserver io.grpc.stub.StreamObserver<Empty>

batchUpdatePartitions(BatchUpdatePartitionsRequest request, StreamObserver<BatchUpdatePartitionsResponse> responseObserver)

public default void batchUpdatePartitions(BatchUpdatePartitionsRequest request, StreamObserver<BatchUpdatePartitionsResponse> responseObserver)

Updates partitions in a table.

Parameters
Name Description
request BatchUpdatePartitionsRequest
responseObserver io.grpc.stub.StreamObserver<BatchUpdatePartitionsResponse>

createHiveCatalog(CreateHiveCatalogRequest request, StreamObserver<HiveCatalog> responseObserver)

public default void createHiveCatalog(CreateHiveCatalogRequest request, StreamObserver<HiveCatalog> responseObserver)

Creates a new hive catalog.

Parameters
Name Description
request CreateHiveCatalogRequest
responseObserver io.grpc.stub.StreamObserver<HiveCatalog>

createHiveDatabase(CreateHiveDatabaseRequest request, StreamObserver<HiveDatabase> responseObserver)

public default void createHiveDatabase(CreateHiveDatabaseRequest request, StreamObserver<HiveDatabase> responseObserver)

Creates a new database.

Parameters
Name Description
request CreateHiveDatabaseRequest
responseObserver io.grpc.stub.StreamObserver<HiveDatabase>

createHiveTable(CreateHiveTableRequest request, StreamObserver<HiveTable> responseObserver)

public default void createHiveTable(CreateHiveTableRequest request, StreamObserver<HiveTable> responseObserver)

Creates a new hive table.

Parameters
Name Description
request CreateHiveTableRequest
responseObserver io.grpc.stub.StreamObserver<HiveTable>

deleteHiveCatalog(DeleteHiveCatalogRequest request, StreamObserver<Empty> responseObserver)

public default void deleteHiveCatalog(DeleteHiveCatalogRequest request, StreamObserver<Empty> responseObserver)

Deletes an existing catalog specified by the catalog ID. Delete will fail if the catalog is not empty.

Parameters
Name Description
request DeleteHiveCatalogRequest
responseObserver io.grpc.stub.StreamObserver<Empty>

deleteHiveDatabase(DeleteHiveDatabaseRequest request, StreamObserver<Empty> responseObserver)

public default void deleteHiveDatabase(DeleteHiveDatabaseRequest request, StreamObserver<Empty> responseObserver)

Deletes an existing database specified by the database name.

Parameters
Name Description
request DeleteHiveDatabaseRequest
responseObserver io.grpc.stub.StreamObserver<Empty>

deleteHiveTable(DeleteHiveTableRequest request, StreamObserver<Empty> responseObserver)

public default void deleteHiveTable(DeleteHiveTableRequest request, StreamObserver<Empty> responseObserver)

Deletes an existing table specified by the table name.

Parameters
Name Description
request DeleteHiveTableRequest
responseObserver io.grpc.stub.StreamObserver<Empty>

getHiveCatalog(GetHiveCatalogRequest request, StreamObserver<HiveCatalog> responseObserver)

public default void getHiveCatalog(GetHiveCatalogRequest request, StreamObserver<HiveCatalog> responseObserver)

Gets the catalog specified by the resource name.

Parameters
Name Description
request GetHiveCatalogRequest
responseObserver io.grpc.stub.StreamObserver<HiveCatalog>

getHiveDatabase(GetHiveDatabaseRequest request, StreamObserver<HiveDatabase> responseObserver)

public default void getHiveDatabase(GetHiveDatabaseRequest request, StreamObserver<HiveDatabase> responseObserver)

Gets the database specified by the resource name.

Parameters
Name Description
request GetHiveDatabaseRequest
responseObserver io.grpc.stub.StreamObserver<HiveDatabase>

getHiveTable(GetHiveTableRequest request, StreamObserver<HiveTable> responseObserver)

public default void getHiveTable(GetHiveTableRequest request, StreamObserver<HiveTable> responseObserver)

Gets the table specified by the resource name.

Parameters
Name Description
request GetHiveTableRequest
responseObserver io.grpc.stub.StreamObserver<HiveTable>

listHiveCatalogs(ListHiveCatalogsRequest request, StreamObserver<ListHiveCatalogsResponse> responseObserver)

public default void listHiveCatalogs(ListHiveCatalogsRequest request, StreamObserver<ListHiveCatalogsResponse> responseObserver)

List all catalogs in a specified project.

Parameters
Name Description
request ListHiveCatalogsRequest
responseObserver io.grpc.stub.StreamObserver<ListHiveCatalogsResponse>

listHiveDatabases(ListHiveDatabasesRequest request, StreamObserver<ListHiveDatabasesResponse> responseObserver)

public default void listHiveDatabases(ListHiveDatabasesRequest request, StreamObserver<ListHiveDatabasesResponse> responseObserver)

List all databases in a specified catalog.

Parameters
Name Description
request ListHiveDatabasesRequest
responseObserver io.grpc.stub.StreamObserver<ListHiveDatabasesResponse>

listHiveTables(ListHiveTablesRequest request, StreamObserver<ListHiveTablesResponse> responseObserver)

public default void listHiveTables(ListHiveTablesRequest request, StreamObserver<ListHiveTablesResponse> responseObserver)

List all hive tables in a specified project under the hive catalog and database.

Parameters
Name Description
request ListHiveTablesRequest
responseObserver io.grpc.stub.StreamObserver<ListHiveTablesResponse>

listPartitions(ListPartitionsRequest request, StreamObserver<ListPartitionsResponse> responseObserver)

public default void listPartitions(ListPartitionsRequest request, StreamObserver<ListPartitionsResponse> responseObserver)

Streams list of partitions from a table.

Parameters
Name Description
request ListPartitionsRequest
responseObserver io.grpc.stub.StreamObserver<ListPartitionsResponse>

updateHiveCatalog(UpdateHiveCatalogRequest request, StreamObserver<HiveCatalog> responseObserver)

public default void updateHiveCatalog(UpdateHiveCatalogRequest request, StreamObserver<HiveCatalog> responseObserver)

Updates an existing catalog.

Parameters
Name Description
request UpdateHiveCatalogRequest
responseObserver io.grpc.stub.StreamObserver<HiveCatalog>

updateHiveDatabase(UpdateHiveDatabaseRequest request, StreamObserver<HiveDatabase> responseObserver)

public default void updateHiveDatabase(UpdateHiveDatabaseRequest request, StreamObserver<HiveDatabase> responseObserver)

Updates an existing database specified by the database name.

Parameters
Name Description
request UpdateHiveDatabaseRequest
responseObserver io.grpc.stub.StreamObserver<HiveDatabase>

updateHiveTable(UpdateHiveTableRequest request, StreamObserver<HiveTable> responseObserver)

public default void updateHiveTable(UpdateHiveTableRequest request, StreamObserver<HiveTable> responseObserver)

Updates an existing table specified by the table name.

Parameters
Name Description
request UpdateHiveTableRequest
responseObserver io.grpc.stub.StreamObserver<HiveTable>