public static final class MetastoreServiceGrpc.MetastoreServiceStub extends AbstractAsyncStub<MetastoreServiceGrpc.MetastoreServiceStub>
BigLake Metastore is a serverless, highly available, multi-tenant runtime
metastore for Google Cloud Data Analytics products.
The BigLake Metastore API defines the following resource model:
- A collection of Google Cloud projects:
/projects/*
- Each project has a collection of available locations:
/locations/*
- Each location 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 >
MetastoreServiceGrpc.MetastoreServiceStub
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.withWaitForReady()
Methods
protected MetastoreServiceGrpc.MetastoreServiceStub 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 void checkLock(CheckLockRequest request, StreamObserver<Lock> responseObserver)
Checks the state of a lock specified by the lock ID.
public void createCatalog(CreateCatalogRequest request, StreamObserver<Catalog> responseObserver)
public void createDatabase(CreateDatabaseRequest request, StreamObserver<Database> responseObserver)
public void createLock(CreateLockRequest request, StreamObserver<Lock> responseObserver)
public void createTable(CreateTableRequest request, StreamObserver<Table> responseObserver)
public void deleteCatalog(DeleteCatalogRequest request, StreamObserver<Catalog> responseObserver)
Deletes an existing catalog specified by the catalog ID.
public void deleteDatabase(DeleteDatabaseRequest request, StreamObserver<Database> responseObserver)
Deletes an existing database specified by the database ID.
public void deleteLock(DeleteLockRequest request, StreamObserver<Empty> responseObserver)
Deletes an existing lock specified by the lock ID.
public void deleteTable(DeleteTableRequest request, StreamObserver<Table> responseObserver)
Deletes an existing table specified by the table ID.
public void getCatalog(GetCatalogRequest request, StreamObserver<Catalog> responseObserver)
Gets the catalog specified by the resource name.
public void getDatabase(GetDatabaseRequest request, StreamObserver<Database> responseObserver)
Gets the database specified by the resource name.
public void getTable(GetTableRequest request, StreamObserver<Table> responseObserver)
Gets the table specified by the resource name.
public void listCatalogs(ListCatalogsRequest request, StreamObserver<ListCatalogsResponse> responseObserver)
List all catalogs in a specified project.
public void listDatabases(ListDatabasesRequest request, StreamObserver<ListDatabasesResponse> responseObserver)
List all databases in a specified catalog.
public void listLocks(ListLocksRequest request, StreamObserver<ListLocksResponse> responseObserver)
List all locks in a specified database.
public void listTables(ListTablesRequest request, StreamObserver<ListTablesResponse> responseObserver)
List all tables in a specified database.
public void updateDatabase(UpdateDatabaseRequest request, StreamObserver<Database> responseObserver)
Updates an existing database specified by the database ID.
public void updateTable(UpdateTableRequest request, StreamObserver<Table> responseObserver)
Updates an existing table specified by the table ID.