public static final class DataplexServiceGrpc.DataplexServiceBlockingStub extends AbstractBlockingStub<DataplexServiceGrpc.DataplexServiceBlockingStub>
A stub to allow clients to do limited 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(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
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.
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.
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 |
|
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.
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.
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.
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)
