Class HiveMetastoreServiceGrpc.HiveMetastoreServiceStub (0.76.0)

0.76.0 (latest) 0.75.0 0.73.0 0.71.0 0.70.0 0.69.0 0.68.0 0.66.0 0.64.0 0.63.0 0.62.0 0.61.0 0.60.0 0.58.0 0.56.0 0.55.0 0.52.0 0.51.0 0.50.0 0.48.0 0.47.0 0.46.0 0.45.0 0.44.0 0.43.0 0.42.0 0.41.0 0.40.0 0.39.0 0.37.0 0.36.0 0.35.0 0.34.0 0.33.0 0.32.0 0.31.0 0.30.0 0.29.0 0.28.0 0.27.0 0.25.0 0.24.0 0.23.0 0.22.0 0.21.0 0.20.0 0.19.0 0.18.0 0.17.0 0.16.0 0.15.0 0.12.0 0.11.0 0.10.0 0.9.0 0.8.0 0.7.0 0.6.0 0.5.0 0.4.0 0.3.0 0.2.0 0.1.0

public static final class HiveMetastoreServiceGrpc.HiveMetastoreServiceStub extends AbstractAsyncStub<HiveMetastoreServiceGrpc.HiveMetastoreServiceStub>

A stub to allow clients to do asynchronous 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.AbstractAsyncStub > HiveMetastoreServiceGrpc.HiveMetastoreServiceStub

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

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

batchCreatePartitions(BatchCreatePartitionsRequest request, StreamObserver<BatchCreatePartitionsResponse> responseObserver)

public 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 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 void batchUpdatePartitions(BatchUpdatePartitionsRequest request, StreamObserver<BatchUpdatePartitionsResponse> responseObserver)

Updates partitions in a table.

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

build(Channel channel, CallOptions callOptions)

protected HiveMetastoreServiceGrpc.HiveMetastoreServiceStub build(Channel channel, CallOptions callOptions)

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

Returns
Type	Description
HiveMetastoreServiceGrpc.HiveMetastoreServiceStub

Overrides

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

createHiveCatalog(CreateHiveCatalogRequest request, StreamObserver<HiveCatalog> responseObserver)

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