Class DataplexServiceGrpc.DataplexServiceImplBase (0.2.2)

public abstract static class DataplexServiceGrpc.DataplexServiceImplBase implements BindableService

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 adminstrator 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 > DataplexServiceGrpc.DataplexServiceImplBase

Implements

io.grpc.BindableService

Constructors

DataplexServiceImplBase()

public DataplexServiceImplBase()

Methods

bindService()

public final ServerServiceDefinition bindService()
Returns
TypeDescription
io.grpc.ServerServiceDefinition

cancelJob(CancelJobRequest request, StreamObserver<Empty> responseObserver)

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

Cancel jobs running for the task resource.

Parameters
NameDescription
requestCancelJobRequest
responseObserverio.grpc.stub.StreamObserver<Empty>

createAsset(CreateAssetRequest request, StreamObserver<Operation> responseObserver)

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

Creates an asset resource.

Parameters
NameDescription
requestCreateAssetRequest
responseObserverio.grpc.stub.StreamObserver<Operation>

createEnvironment(CreateEnvironmentRequest request, StreamObserver<Operation> responseObserver)

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

Create an environment resource.

Parameters
NameDescription
requestCreateEnvironmentRequest
responseObserverio.grpc.stub.StreamObserver<Operation>

createLake(CreateLakeRequest request, StreamObserver<Operation> responseObserver)

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

Creates a lake resource.

Parameters
NameDescription
requestCreateLakeRequest
responseObserverio.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
NameDescription
requestCreateTaskRequest
responseObserverio.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
NameDescription
requestCreateZoneRequest
responseObserverio.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
NameDescription
requestDeleteAssetRequest
responseObserverio.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
NameDescription
requestDeleteEnvironmentRequest
responseObserverio.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
NameDescription
requestDeleteLakeRequest
responseObserverio.grpc.stub.StreamObserver<Operation>

deleteTask(DeleteTaskRequest request, StreamObserver<Operation> responseObserver)

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

Delete the task resource.

Parameters
NameDescription
requestDeleteTaskRequest
responseObserverio.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
NameDescription
requestDeleteZoneRequest
responseObserverio.grpc.stub.StreamObserver<Operation>

getAsset(GetAssetRequest request, StreamObserver<Asset> responseObserver)

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

Retrieves an asset resource.

Parameters
NameDescription
requestGetAssetRequest
responseObserverio.grpc.stub.StreamObserver<Asset>

getEnvironment(GetEnvironmentRequest request, StreamObserver<Environment> responseObserver)

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

Get environment resource.

Parameters
NameDescription
requestGetEnvironmentRequest
responseObserverio.grpc.stub.StreamObserver<Environment>

getJob(GetJobRequest request, StreamObserver<Job> responseObserver)

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

Get job resource.

Parameters
NameDescription
requestGetJobRequest
responseObserverio.grpc.stub.StreamObserver<Job>

getLake(GetLakeRequest request, StreamObserver<Lake> responseObserver)

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

Retrieves a lake resource.

Parameters
NameDescription
requestGetLakeRequest
responseObserverio.grpc.stub.StreamObserver<Lake>

getTask(GetTaskRequest request, StreamObserver<Task> responseObserver)

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

Get task resource.

Parameters
NameDescription
requestGetTaskRequest
responseObserverio.grpc.stub.StreamObserver<Task>

getZone(GetZoneRequest request, StreamObserver<Zone> responseObserver)

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

Retrieves a zone resource.

Parameters
NameDescription
requestGetZoneRequest
responseObserverio.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
NameDescription
requestListAssetActionsRequest
responseObserverio.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
NameDescription
requestListAssetsRequest
responseObserverio.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
NameDescription
requestListEnvironmentsRequest
responseObserverio.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
NameDescription
requestListJobsRequest
responseObserverio.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
NameDescription
requestListLakeActionsRequest
responseObserverio.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
NameDescription
requestListLakesRequest
responseObserverio.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
NameDescription
requestListSessionsRequest
responseObserverio.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
NameDescription
requestListTasksRequest
responseObserverio.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
NameDescription
requestListZoneActionsRequest
responseObserverio.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
NameDescription
requestListZonesRequest
responseObserverio.grpc.stub.StreamObserver<ListZonesResponse>

updateAsset(UpdateAssetRequest request, StreamObserver<Operation> responseObserver)

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

Updates an asset resource.

Parameters
NameDescription
requestUpdateAssetRequest
responseObserverio.grpc.stub.StreamObserver<Operation>

updateEnvironment(UpdateEnvironmentRequest request, StreamObserver<Operation> responseObserver)

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

Update the environment resource.

Parameters
NameDescription
requestUpdateEnvironmentRequest
responseObserverio.grpc.stub.StreamObserver<Operation>

updateLake(UpdateLakeRequest request, StreamObserver<Operation> responseObserver)

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

Updates a lake resource.

Parameters
NameDescription
requestUpdateLakeRequest
responseObserverio.grpc.stub.StreamObserver<Operation>

updateTask(UpdateTaskRequest request, StreamObserver<Operation> responseObserver)

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

Update the task resource.

Parameters
NameDescription
requestUpdateTaskRequest
responseObserverio.grpc.stub.StreamObserver<Operation>

updateZone(UpdateZoneRequest request, StreamObserver<Operation> responseObserver)

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

Updates a zone resource.

Parameters
NameDescription
requestUpdateZoneRequest
responseObserverio.grpc.stub.StreamObserver<Operation>