public static final class DataplexServiceGrpc.DataplexServiceBlockingStub extends AbstractBlockingStub<DataplexServiceGrpc.DataplexServiceBlockingStub>
A stub to allow clients to do synchronous rpc calls to service DataplexService.
Dataplex service provides data lakes as a service. The primary resources
offered by this service are Lakes, Zones and Assets which collectively allow
a data administrator to organize, manage, secure and catalog data across
their organization located across cloud projects in a variety of storage
systems including Cloud Storage and BigQuery.
Inheritance
java.lang.Object >
io.grpc.stub.AbstractStub >
io.grpc.stub.AbstractBlockingStub >
DataplexServiceGrpc.DataplexServiceBlockingStub
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(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
build(Channel channel, CallOptions callOptions)
protected DataplexServiceGrpc.DataplexServiceBlockingStub 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)
cancelJob(CancelJobRequest request)
public Empty cancelJob(CancelJobRequest request)
Cancel jobs running for the task resource.
| Returns |
| Type |
Description |
Empty |
|
createAsset(CreateAssetRequest request)
public Operation createAsset(CreateAssetRequest request)
Creates an asset resource.
createEnvironment(CreateEnvironmentRequest request)
public Operation createEnvironment(CreateEnvironmentRequest request)
Create an environment resource.
createLake(CreateLakeRequest request)
public Operation createLake(CreateLakeRequest request)
createTask(CreateTaskRequest request)
public Operation createTask(CreateTaskRequest request)
Creates a task resource within a lake.
createZone(CreateZoneRequest request)
public Operation createZone(CreateZoneRequest request)
Creates a zone resource within a lake.
deleteAsset(DeleteAssetRequest request)
public Operation deleteAsset(DeleteAssetRequest request)
Deletes an asset resource. The referenced storage resource is detached
(default) or deleted based on the associated Lifecycle policy.
deleteEnvironment(DeleteEnvironmentRequest request)
public Operation deleteEnvironment(DeleteEnvironmentRequest request)
Delete the environment resource. All the child resources must have been
deleted before environment deletion can be initiated.
deleteLake(DeleteLakeRequest request)
public Operation deleteLake(DeleteLakeRequest request)
Deletes a lake resource. All zones within the lake must be deleted before
the lake can be deleted.
deleteTask(DeleteTaskRequest request)
public Operation deleteTask(DeleteTaskRequest request)
Delete the task resource.
deleteZone(DeleteZoneRequest request)
public Operation deleteZone(DeleteZoneRequest request)
Deletes a zone resource. All assets within a zone must be deleted before
the zone can be deleted.
getAsset(GetAssetRequest request)
public Asset getAsset(GetAssetRequest request)
Retrieves an asset resource.
| Returns |
| Type |
Description |
Asset |
|
getEnvironment(GetEnvironmentRequest request)
public Environment getEnvironment(GetEnvironmentRequest request)
Get environment resource.
getJob(GetJobRequest request)
public Job getJob(GetJobRequest request)
| Returns |
| Type |
Description |
Job |
|
getLake(GetLakeRequest request)
public Lake getLake(GetLakeRequest request)
Retrieves a lake resource.
| Returns |
| Type |
Description |
Lake |
|
getTask(GetTaskRequest request)
public Task getTask(GetTaskRequest request)
| Returns |
| Type |
Description |
Task |
|
getZone(GetZoneRequest request)
public Zone getZone(GetZoneRequest request)
Retrieves a zone resource.
| Returns |
| Type |
Description |
Zone |
|
listAssetActions(ListAssetActionsRequest request)
public ListActionsResponse listAssetActions(ListAssetActionsRequest request)
Lists action resources in an asset.
listAssets(ListAssetsRequest request)
public ListAssetsResponse listAssets(ListAssetsRequest request)
Lists asset resources in a zone.
listEnvironments(ListEnvironmentsRequest request)
public ListEnvironmentsResponse listEnvironments(ListEnvironmentsRequest request)
Lists environments under the given lake.
listJobs(ListJobsRequest request)
public ListJobsResponse listJobs(ListJobsRequest request)
Lists Jobs under the given task.
listLakeActions(ListLakeActionsRequest request)
public ListActionsResponse listLakeActions(ListLakeActionsRequest request)
Lists action resources in a lake.
listLakes(ListLakesRequest request)
public ListLakesResponse listLakes(ListLakesRequest request)
Lists lake resources in a project and location.
listSessions(ListSessionsRequest request)
public ListSessionsResponse listSessions(ListSessionsRequest request)
Lists session resources in an environment.
listTasks(ListTasksRequest request)
public ListTasksResponse listTasks(ListTasksRequest request)
Lists tasks under the given lake.
listZoneActions(ListZoneActionsRequest request)
public ListActionsResponse listZoneActions(ListZoneActionsRequest request)
Lists action resources in a zone.
listZones(ListZonesRequest request)
public ListZonesResponse listZones(ListZonesRequest request)
Lists zone resources in a lake.
runTask(RunTaskRequest request)
public RunTaskResponse runTask(RunTaskRequest request)
Run an on demand execution of a Task.
updateAsset(UpdateAssetRequest request)
public Operation updateAsset(UpdateAssetRequest request)
Updates an asset resource.
updateEnvironment(UpdateEnvironmentRequest request)
public Operation updateEnvironment(UpdateEnvironmentRequest request)
Update the environment resource.
updateLake(UpdateLakeRequest request)
public Operation updateLake(UpdateLakeRequest request)
updateTask(UpdateTaskRequest request)
public Operation updateTask(UpdateTaskRequest request)
Update the task resource.
updateZone(UpdateZoneRequest request)
public Operation updateZone(UpdateZoneRequest request)
