Some or all of the information on this page might not apply to Cloud de Confiance by S3NS. See Differences from Google Cloud for more details.

Class DataplexServiceGrpc.DataplexServiceStub (1.50.0)

public static final class DataplexServiceGrpc.DataplexServiceStub extends AbstractAsyncStub<DataplexServiceGrpc.DataplexServiceStub>

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

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

build(Channel channel, CallOptions callOptions)

protected DataplexServiceGrpc.DataplexServiceStub build(Channel channel, CallOptions callOptions)

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

Returns
Type	Description
`DataplexServiceGrpc.DataplexServiceStub`

Overrides

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

cancelJob(CancelJobRequest request, StreamObserver<Empty> responseObserver)

public void cancelJob(CancelJobRequest request, StreamObserver<Empty> responseObserver)

Cancel jobs running for the task resource.

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

createAsset(CreateAssetRequest request, StreamObserver<Operation> responseObserver)

public void createAsset(CreateAssetRequest request, StreamObserver<Operation> responseObserver)

Creates an asset resource.

Parameters
Name	Description
`request`	`CreateAssetRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Operation>`

createEnvironment(CreateEnvironmentRequest request, StreamObserver<Operation> responseObserver)

public void createEnvironment(CreateEnvironmentRequest request, StreamObserver<Operation> responseObserver)

Create an environment resource.

Parameters
Name	Description
`request`	`CreateEnvironmentRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Operation>`

createLake(CreateLakeRequest request, StreamObserver<Operation> responseObserver)

public void createLake(CreateLakeRequest request, StreamObserver<Operation> responseObserver)

Creates a lake resource.

Parameters
Name	Description
`request`	`CreateLakeRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Operation>`

createTask(CreateTaskRequest request, StreamObserver<Operation> responseObserver)

public void createTask(CreateTaskRequest request, StreamObserver<Operation> responseObserver)

Creates a task resource within a lake.

Parameters
Name	Description
`request`	`CreateTaskRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Operation>`

createZone(CreateZoneRequest request, StreamObserver<Operation> responseObserver)

public void createZone(CreateZoneRequest request, StreamObserver<Operation> responseObserver)

Creates a zone resource within a lake.

Parameters
Name	Description
`request`	`CreateZoneRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Operation>`

deleteAsset(DeleteAssetRequest request, StreamObserver<Operation> responseObserver)

public void deleteAsset(DeleteAssetRequest request, StreamObserver<Operation> responseObserver)

Deletes an asset resource. The referenced storage resource is detached (default) or deleted based on the associated Lifecycle policy.

Parameters
Name	Description
`request`	`DeleteAssetRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Operation>`

deleteEnvironment(DeleteEnvironmentRequest request, StreamObserver<Operation> responseObserver)

public void deleteEnvironment(DeleteEnvironmentRequest request, StreamObserver<Operation> responseObserver)

Delete the environment resource. All the child resources must have been deleted before environment deletion can be initiated.

Parameters
Name	Description
`request`	`DeleteEnvironmentRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Operation>`

deleteLake(DeleteLakeRequest request, StreamObserver<Operation> responseObserver)

public void deleteLake(DeleteLakeRequest request, StreamObserver<Operation> responseObserver)

Deletes a lake resource. All zones within the lake must be deleted before the lake can be deleted.

Parameters
Name	Description
`request`	`DeleteLakeRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Operation>`

deleteTask(DeleteTaskRequest request, StreamObserver<Operation> responseObserver)

public void deleteTask(DeleteTaskRequest request, StreamObserver<Operation> responseObserver)

Delete the task resource.

Parameters
Name	Description
`request`	`DeleteTaskRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Operation>`

deleteZone(DeleteZoneRequest request, StreamObserver<Operation> responseObserver)

public void deleteZone(DeleteZoneRequest request, StreamObserver<Operation> responseObserver)

Deletes a zone resource. All assets within a zone must be deleted before the zone can be deleted.

Parameters
Name	Description
`request`	`DeleteZoneRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Operation>`

getAsset(GetAssetRequest request, StreamObserver<Asset> responseObserver)

public void getAsset(GetAssetRequest request, StreamObserver<Asset> responseObserver)

Retrieves an asset resource.

Parameters
Name	Description
`request`	`GetAssetRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Asset>`

getEnvironment(GetEnvironmentRequest request, StreamObserver<Environment> responseObserver)

public void getEnvironment(GetEnvironmentRequest request, StreamObserver<Environment> responseObserver)

Get environment resource.

Parameters
Name	Description
`request`	`GetEnvironmentRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Environment>`

getJob(GetJobRequest request, StreamObserver<Job> responseObserver)

public void getJob(GetJobRequest request, StreamObserver<Job> responseObserver)

Get job resource.

Parameters
Name	Description
`request`	`GetJobRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Job>`

getLake(GetLakeRequest request, StreamObserver<Lake> responseObserver)

public void getLake(GetLakeRequest request, StreamObserver<Lake> responseObserver)

Retrieves a lake resource.

Parameters
Name	Description
`request`	`GetLakeRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Lake>`

getTask(GetTaskRequest request, StreamObserver<Task> responseObserver)

public void getTask(GetTaskRequest request, StreamObserver<Task> responseObserver)

Get task resource.

Parameters
Name	Description
`request`	`GetTaskRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Task>`

getZone(GetZoneRequest request, StreamObserver<Zone> responseObserver)

public void getZone(GetZoneRequest request, StreamObserver<Zone> responseObserver)

Retrieves a zone resource.

Parameters
Name	Description
`request`	`GetZoneRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Zone>`

listAssetActions(ListAssetActionsRequest request, StreamObserver<ListActionsResponse> responseObserver)

public void listAssetActions(ListAssetActionsRequest request, StreamObserver<ListActionsResponse> responseObserver)

Lists action resources in an asset.

Parameters
Name	Description
`request`	`ListAssetActionsRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<ListActionsResponse>`

listAssets(ListAssetsRequest request, StreamObserver<ListAssetsResponse> responseObserver)

public void listAssets(ListAssetsRequest request, StreamObserver<ListAssetsResponse> responseObserver)

Lists asset resources in a zone.

Parameters
Name	Description
`request`	`ListAssetsRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<ListAssetsResponse>`

listEnvironments(ListEnvironmentsRequest request, StreamObserver<ListEnvironmentsResponse> responseObserver)

public void listEnvironments(ListEnvironmentsRequest request, StreamObserver<ListEnvironmentsResponse> responseObserver)

Lists environments under the given lake.

Parameters
Name	Description
`request`	`ListEnvironmentsRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<ListEnvironmentsResponse>`

listJobs(ListJobsRequest request, StreamObserver<ListJobsResponse> responseObserver)

public void listJobs(ListJobsRequest request, StreamObserver<ListJobsResponse> responseObserver)

Lists Jobs under the given task.

Parameters
Name	Description
`request`	`ListJobsRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<ListJobsResponse>`

listLakeActions(ListLakeActionsRequest request, StreamObserver<ListActionsResponse> responseObserver)

public void listLakeActions(ListLakeActionsRequest request, StreamObserver<ListActionsResponse> responseObserver)

Lists action resources in a lake.

Parameters
Name	Description
`request`	`ListLakeActionsRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<ListActionsResponse>`

listLakes(ListLakesRequest request, StreamObserver<ListLakesResponse> responseObserver)

public void listLakes(ListLakesRequest request, StreamObserver<ListLakesResponse> responseObserver)

Lists lake resources in a project and location.

Parameters
Name	Description
`request`	`ListLakesRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<ListLakesResponse>`

listSessions(ListSessionsRequest request, StreamObserver<ListSessionsResponse> responseObserver)

public void listSessions(ListSessionsRequest request, StreamObserver<ListSessionsResponse> responseObserver)

Lists session resources in an environment.

Parameters
Name	Description
`request`	`ListSessionsRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<ListSessionsResponse>`

listTasks(ListTasksRequest request, StreamObserver<ListTasksResponse> responseObserver)

public void listTasks(ListTasksRequest request, StreamObserver<ListTasksResponse> responseObserver)

Lists tasks under the given lake.

Parameters
Name	Description
`request`	`ListTasksRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<ListTasksResponse>`

listZoneActions(ListZoneActionsRequest request, StreamObserver<ListActionsResponse> responseObserver)

public void listZoneActions(ListZoneActionsRequest request, StreamObserver<ListActionsResponse> responseObserver)

Lists action resources in a zone.

Parameters
Name	Description
`request`	`ListZoneActionsRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<ListActionsResponse>`

listZones(ListZonesRequest request, StreamObserver<ListZonesResponse> responseObserver)

public void listZones(ListZonesRequest request, StreamObserver<ListZonesResponse> responseObserver)

Lists zone resources in a lake.

Parameters
Name	Description
`request`	`ListZonesRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<ListZonesResponse>`

runTask(RunTaskRequest request, StreamObserver<RunTaskResponse> responseObserver)

public void runTask(RunTaskRequest request, StreamObserver<RunTaskResponse> responseObserver)

Run an on demand execution of a Task.

Parameters
Name	Description
`request`	`RunTaskRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<RunTaskResponse>`

updateAsset(UpdateAssetRequest request, StreamObserver<Operation> responseObserver)

public void updateAsset(UpdateAssetRequest request, StreamObserver<Operation> responseObserver)

Updates an asset resource.

Parameters
Name	Description
`request`	`UpdateAssetRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Operation>`

updateEnvironment(UpdateEnvironmentRequest request, StreamObserver<Operation> responseObserver)

public void updateEnvironment(UpdateEnvironmentRequest request, StreamObserver<Operation> responseObserver)

Update the environment resource.

Parameters
Name	Description
`request`	`UpdateEnvironmentRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Operation>`

updateLake(UpdateLakeRequest request, StreamObserver<Operation> responseObserver)

public void updateLake(UpdateLakeRequest request, StreamObserver<Operation> responseObserver)

Updates a lake resource.

Parameters
Name	Description
`request`	`UpdateLakeRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Operation>`

updateTask(UpdateTaskRequest request, StreamObserver<Operation> responseObserver)

public void updateTask(UpdateTaskRequest request, StreamObserver<Operation> responseObserver)

Update the task resource.

Parameters
Name	Description
`request`	`UpdateTaskRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Operation>`

updateZone(UpdateZoneRequest request, StreamObserver<Operation> responseObserver)

public void updateZone(UpdateZoneRequest request, StreamObserver<Operation> responseObserver)

Updates a zone resource.

Parameters
Name	Description
`request`	`UpdateZoneRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Operation>`