- 1.51.0 (latest)
- 1.50.0
- 1.49.0
- 1.47.0
- 1.46.0
- 1.45.0
- 1.44.0
- 1.43.0
- 1.42.0
- 1.41.0
- 1.40.0
- 1.39.0
- 1.38.0
- 1.37.0
- 1.35.0
- 1.34.0
- 1.33.0
- 1.32.0
- 1.31.0
- 1.30.0
- 1.29.0
- 1.28.0
- 1.27.0
- 1.26.0
- 1.25.0
- 1.22.0
- 1.21.0
- 1.20.0
- 1.19.0
- 1.18.0
- 1.17.0
- 1.16.0
- 1.15.0
- 1.14.0
- 1.13.0
- 1.12.0
- 1.11.0
- 1.10.0
- 1.9.0
- 1.7.0
- 1.6.0
- 1.5.0
- 1.4.0
- 1.3.0
- 1.2.0
- 1.1.2
- 1.0.1
- 0.2.2
public class DataplexServiceClient implements BackgroundResource
Service Description: 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.
This class provides the ability to make remote calls to the backing service through method calls that map to API methods. Sample code to get started:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
LakeName name = LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]");
Lake response = dataplexServiceClient.getLake(name);
}
Note: close() needs to be called on the DataplexServiceClient object to clean up resources such as threads. In the example above, try-with-resources is used, which automatically calls close().
The surface of this class includes several types of Java methods for each of the API's methods:
- A "flattened" method. With this type of method, the fields of the request type have been converted into function parameters. It may be the case that not all fields are available as parameters, and not every API method will have a flattened method entry point.
- A "request object" method. This type of method only takes one parameter, a request object, which must be constructed before the call. Not every API method will have a request object method.
- A "callable" method. This type of method takes no parameters and returns an immutable API callable object, which can be used to initiate calls to the service.
See the individual methods for example code.
Many parameters require resource names to be formatted in a particular way. To assist with these names, this class includes a format method for each type of name, and additionally a parse method to extract the individual identifiers contained within names that are returned.
This class can be customized by passing in a custom instance of DataplexServiceSettings to create(). For example:
To customize credentials:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
DataplexServiceSettings dataplexServiceSettings =
DataplexServiceSettings.newBuilder()
.setCredentialsProvider(FixedCredentialsProvider.create(myCredentials))
.build();
DataplexServiceClient dataplexServiceClient =
DataplexServiceClient.create(dataplexServiceSettings);
To customize the endpoint:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
DataplexServiceSettings dataplexServiceSettings =
DataplexServiceSettings.newBuilder().setEndpoint(myEndpoint).build();
DataplexServiceClient dataplexServiceClient =
DataplexServiceClient.create(dataplexServiceSettings);
Please refer to the GitHub repository's samples for more quickstart code snippets.
Implements
BackgroundResourceStatic Methods
create()
public static final DataplexServiceClient create()
Constructs an instance of DataplexServiceClient with default settings.
Type | Description |
DataplexServiceClient |
Type | Description |
IOException |
create(DataplexServiceSettings settings)
public static final DataplexServiceClient create(DataplexServiceSettings settings)
Constructs an instance of DataplexServiceClient, using the given settings. The channels are created based on the settings passed in, or defaults for any settings that are not set.
Name | Description |
settings | DataplexServiceSettings |
Type | Description |
DataplexServiceClient |
Type | Description |
IOException |
create(DataplexServiceStub stub)
public static final DataplexServiceClient create(DataplexServiceStub stub)
Constructs an instance of DataplexServiceClient, using the given stub for making calls. This is for advanced usage - prefer using create(DataplexServiceSettings).
Name | Description |
stub | DataplexServiceStub |
Type | Description |
DataplexServiceClient |
Constructors
DataplexServiceClient(DataplexServiceSettings settings)
protected DataplexServiceClient(DataplexServiceSettings settings)
Constructs an instance of DataplexServiceClient, using the given settings. This is protected so that it is easy to make a subclass, but otherwise, the static factory methods should be preferred.
Name | Description |
settings | DataplexServiceSettings |
DataplexServiceClient(DataplexServiceStub stub)
protected DataplexServiceClient(DataplexServiceStub stub)
Name | Description |
stub | DataplexServiceStub |
Methods
awaitTermination(long duration, TimeUnit unit)
public boolean awaitTermination(long duration, TimeUnit unit)
Name | Description |
duration | long |
unit | TimeUnit |
Type | Description |
boolean |
Type | Description |
InterruptedException |
cancelJob(CancelJobRequest request)
public final void cancelJob(CancelJobRequest request)
Cancel jobs running for the task resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
CancelJobRequest request =
CancelJobRequest.newBuilder()
.setName(
JobName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[TASK]", "[JOB]").toString())
.build();
dataplexServiceClient.cancelJob(request);
}
Name | Description |
request | CancelJobRequest The request object containing all of the parameters for the API call. |
cancelJob(JobName name)
public final void cancelJob(JobName name)
Cancel jobs running for the task resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[TASK]", "[JOB]");
dataplexServiceClient.cancelJob(name);
}
Name | Description |
name | JobName Required. The resource name of the job:
|
cancelJob(String name)
public final void cancelJob(String name)
Cancel jobs running for the task resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
String name = JobName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[TASK]", "[JOB]").toString();
dataplexServiceClient.cancelJob(name);
}
Name | Description |
name | String Required. The resource name of the job:
|
cancelJobCallable()
public final UnaryCallable<CancelJobRequest,Empty> cancelJobCallable()
Cancel jobs running for the task resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
CancelJobRequest request =
CancelJobRequest.newBuilder()
.setName(
JobName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[TASK]", "[JOB]").toString())
.build();
ApiFuture<Empty> future = dataplexServiceClient.cancelJobCallable().futureCall(request);
// Do something.
future.get();
}
Type | Description |
UnaryCallable<CancelJobRequest,Empty> |
close()
public final void close()
createAssetAsync(CreateAssetRequest request)
public final OperationFuture<Asset,OperationMetadata> createAssetAsync(CreateAssetRequest request)
Creates an asset resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
CreateAssetRequest request =
CreateAssetRequest.newBuilder()
.setParent(ZoneName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]").toString())
.setAssetId("assetId-704776149")
.setAsset(Asset.newBuilder().build())
.setValidateOnly(true)
.build();
Asset response = dataplexServiceClient.createAssetAsync(request).get();
}
Name | Description |
request | CreateAssetRequest The request object containing all of the parameters for the API call. |
Type | Description |
OperationFuture<Asset,OperationMetadata> |
createAssetAsync(ZoneName parent, Asset asset, String assetId)
public final OperationFuture<Asset,OperationMetadata> createAssetAsync(ZoneName parent, Asset asset, String assetId)
Creates an asset resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ZoneName parent = ZoneName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]");
Asset asset = Asset.newBuilder().build();
String assetId = "assetId-704776149";
Asset response = dataplexServiceClient.createAssetAsync(parent, asset, assetId).get();
}
Name | Description |
parent | ZoneName Required. The resource name of the parent zone:
|
asset | Asset Required. Asset resource. |
assetId | String Required. Asset identifier. This ID will be used to generate names such as table names when publishing metadata to Hive Metastore and BigQuery.
|
Type | Description |
OperationFuture<Asset,OperationMetadata> |
createAssetAsync(String parent, Asset asset, String assetId)
public final OperationFuture<Asset,OperationMetadata> createAssetAsync(String parent, Asset asset, String assetId)
Creates an asset resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
String parent = ZoneName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]").toString();
Asset asset = Asset.newBuilder().build();
String assetId = "assetId-704776149";
Asset response = dataplexServiceClient.createAssetAsync(parent, asset, assetId).get();
}
Name | Description |
parent | String Required. The resource name of the parent zone:
|
asset | Asset Required. Asset resource. |
assetId | String Required. Asset identifier. This ID will be used to generate names such as table names when publishing metadata to Hive Metastore and BigQuery.
|
Type | Description |
OperationFuture<Asset,OperationMetadata> |
createAssetCallable()
public final UnaryCallable<CreateAssetRequest,Operation> createAssetCallable()
Creates an asset resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
CreateAssetRequest request =
CreateAssetRequest.newBuilder()
.setParent(ZoneName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]").toString())
.setAssetId("assetId-704776149")
.setAsset(Asset.newBuilder().build())
.setValidateOnly(true)
.build();
ApiFuture<Operation> future = dataplexServiceClient.createAssetCallable().futureCall(request);
// Do something.
Operation response = future.get();
}
Type | Description |
UnaryCallable<CreateAssetRequest,Operation> |
createAssetOperationCallable()
public final OperationCallable<CreateAssetRequest,Asset,OperationMetadata> createAssetOperationCallable()
Creates an asset resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
CreateAssetRequest request =
CreateAssetRequest.newBuilder()
.setParent(ZoneName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]").toString())
.setAssetId("assetId-704776149")
.setAsset(Asset.newBuilder().build())
.setValidateOnly(true)
.build();
OperationFuture<Asset, OperationMetadata> future =
dataplexServiceClient.createAssetOperationCallable().futureCall(request);
// Do something.
Asset response = future.get();
}
Type | Description |
OperationCallable<CreateAssetRequest,Asset,OperationMetadata> |
createEnvironmentAsync(CreateEnvironmentRequest request)
public final OperationFuture<Environment,OperationMetadata> createEnvironmentAsync(CreateEnvironmentRequest request)
Create an environment resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
CreateEnvironmentRequest request =
CreateEnvironmentRequest.newBuilder()
.setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
.setEnvironmentId("environmentId-950205810")
.setEnvironment(Environment.newBuilder().build())
.setValidateOnly(true)
.build();
Environment response = dataplexServiceClient.createEnvironmentAsync(request).get();
}
Name | Description |
request | CreateEnvironmentRequest The request object containing all of the parameters for the API call. |
Type | Description |
OperationFuture<Environment,OperationMetadata> |
createEnvironmentAsync(LakeName parent, Environment environment, String environmentId)
public final OperationFuture<Environment,OperationMetadata> createEnvironmentAsync(LakeName parent, Environment environment, String environmentId)
Create an environment resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
LakeName parent = LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]");
Environment environment = Environment.newBuilder().build();
String environmentId = "environmentId-950205810";
Environment response =
dataplexServiceClient.createEnvironmentAsync(parent, environment, environmentId).get();
}
Name | Description |
parent | LakeName Required. The resource name of the parent lake: projects/{project_id}/locations/{location_id}/lakes/{lake_id} |
environment | Environment Required. Environment resource. |
environmentId | String Required. Environment identifier.
|
Type | Description |
OperationFuture<Environment,OperationMetadata> |
createEnvironmentAsync(String parent, Environment environment, String environmentId)
public final OperationFuture<Environment,OperationMetadata> createEnvironmentAsync(String parent, Environment environment, String environmentId)
Create an environment resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
String parent = LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString();
Environment environment = Environment.newBuilder().build();
String environmentId = "environmentId-950205810";
Environment response =
dataplexServiceClient.createEnvironmentAsync(parent, environment, environmentId).get();
}
Name | Description |
parent | String Required. The resource name of the parent lake: projects/{project_id}/locations/{location_id}/lakes/{lake_id} |
environment | Environment Required. Environment resource. |
environmentId | String Required. Environment identifier.
|
Type | Description |
OperationFuture<Environment,OperationMetadata> |
createEnvironmentCallable()
public final UnaryCallable<CreateEnvironmentRequest,Operation> createEnvironmentCallable()
Create an environment resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
CreateEnvironmentRequest request =
CreateEnvironmentRequest.newBuilder()
.setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
.setEnvironmentId("environmentId-950205810")
.setEnvironment(Environment.newBuilder().build())
.setValidateOnly(true)
.build();
ApiFuture<Operation> future =
dataplexServiceClient.createEnvironmentCallable().futureCall(request);
// Do something.
Operation response = future.get();
}
Type | Description |
UnaryCallable<CreateEnvironmentRequest,Operation> |
createEnvironmentOperationCallable()
public final OperationCallable<CreateEnvironmentRequest,Environment,OperationMetadata> createEnvironmentOperationCallable()
Create an environment resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
CreateEnvironmentRequest request =
CreateEnvironmentRequest.newBuilder()
.setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
.setEnvironmentId("environmentId-950205810")
.setEnvironment(Environment.newBuilder().build())
.setValidateOnly(true)
.build();
OperationFuture<Environment, OperationMetadata> future =
dataplexServiceClient.createEnvironmentOperationCallable().futureCall(request);
// Do something.
Environment response = future.get();
}
Type | Description |
OperationCallable<CreateEnvironmentRequest,Environment,OperationMetadata> |
createLakeAsync(CreateLakeRequest request)
public final OperationFuture<Lake,OperationMetadata> createLakeAsync(CreateLakeRequest request)
Creates a lake resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
CreateLakeRequest request =
CreateLakeRequest.newBuilder()
.setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
.setLakeId("lakeId-1110150390")
.setLake(Lake.newBuilder().build())
.setValidateOnly(true)
.build();
Lake response = dataplexServiceClient.createLakeAsync(request).get();
}
Name | Description |
request | CreateLakeRequest The request object containing all of the parameters for the API call. |
Type | Description |
OperationFuture<Lake,OperationMetadata> |
createLakeAsync(LocationName parent, Lake lake, String lakeId)
public final OperationFuture<Lake,OperationMetadata> createLakeAsync(LocationName parent, Lake lake, String lakeId)
Creates a lake resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
Lake lake = Lake.newBuilder().build();
String lakeId = "lakeId-1110150390";
Lake response = dataplexServiceClient.createLakeAsync(parent, lake, lakeId).get();
}
Name | Description |
parent | LocationName Required. The resource name of the lake location, of the form:
projects/{project_number}/locations/{location_id} where |
lake | Lake Required. Lake resource |
lakeId | String Required. Lake identifier. This ID will be used to generate names such as database and dataset names when publishing metadata to Hive Metastore and BigQuery.
|
Type | Description |
OperationFuture<Lake,OperationMetadata> |
createLakeAsync(String parent, Lake lake, String lakeId)
public final OperationFuture<Lake,OperationMetadata> createLakeAsync(String parent, Lake lake, String lakeId)
Creates a lake resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
Lake lake = Lake.newBuilder().build();
String lakeId = "lakeId-1110150390";
Lake response = dataplexServiceClient.createLakeAsync(parent, lake, lakeId).get();
}
Name | Description |
parent | String Required. The resource name of the lake location, of the form:
projects/{project_number}/locations/{location_id} where |
lake | Lake Required. Lake resource |
lakeId | String Required. Lake identifier. This ID will be used to generate names such as database and dataset names when publishing metadata to Hive Metastore and BigQuery.
|
Type | Description |
OperationFuture<Lake,OperationMetadata> |
createLakeCallable()
public final UnaryCallable<CreateLakeRequest,Operation> createLakeCallable()
Creates a lake resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
CreateLakeRequest request =
CreateLakeRequest.newBuilder()
.setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
.setLakeId("lakeId-1110150390")
.setLake(Lake.newBuilder().build())
.setValidateOnly(true)
.build();
ApiFuture<Operation> future = dataplexServiceClient.createLakeCallable().futureCall(request);
// Do something.
Operation response = future.get();
}
Type | Description |
UnaryCallable<CreateLakeRequest,Operation> |
createLakeOperationCallable()
public final OperationCallable<CreateLakeRequest,Lake,OperationMetadata> createLakeOperationCallable()
Creates a lake resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
CreateLakeRequest request =
CreateLakeRequest.newBuilder()
.setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
.setLakeId("lakeId-1110150390")
.setLake(Lake.newBuilder().build())
.setValidateOnly(true)
.build();
OperationFuture<Lake, OperationMetadata> future =
dataplexServiceClient.createLakeOperationCallable().futureCall(request);
// Do something.
Lake response = future.get();
}
Type | Description |
OperationCallable<CreateLakeRequest,Lake,OperationMetadata> |
createTaskAsync(CreateTaskRequest request)
public final OperationFuture<Task,OperationMetadata> createTaskAsync(CreateTaskRequest request)
Creates a task resource within a lake.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
CreateTaskRequest request =
CreateTaskRequest.newBuilder()
.setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
.setTaskId("taskId-880873088")
.setTask(Task.newBuilder().build())
.setValidateOnly(true)
.build();
Task response = dataplexServiceClient.createTaskAsync(request).get();
}
Name | Description |
request | CreateTaskRequest The request object containing all of the parameters for the API call. |
Type | Description |
OperationFuture<Task,OperationMetadata> |
createTaskAsync(LakeName parent, Task task, String taskId)
public final OperationFuture<Task,OperationMetadata> createTaskAsync(LakeName parent, Task task, String taskId)
Creates a task resource within a lake.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
LakeName parent = LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]");
Task task = Task.newBuilder().build();
String taskId = "taskId-880873088";
Task response = dataplexServiceClient.createTaskAsync(parent, task, taskId).get();
}
Name | Description |
parent | LakeName Required. The resource name of the parent lake:
|
task | Task Required. Task resource. |
taskId | String Required. Task identifier. |
Type | Description |
OperationFuture<Task,OperationMetadata> |
createTaskAsync(String parent, Task task, String taskId)
public final OperationFuture<Task,OperationMetadata> createTaskAsync(String parent, Task task, String taskId)
Creates a task resource within a lake.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
String parent = LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString();
Task task = Task.newBuilder().build();
String taskId = "taskId-880873088";
Task response = dataplexServiceClient.createTaskAsync(parent, task, taskId).get();
}
Name | Description |
parent | String Required. The resource name of the parent lake:
|
task | Task Required. Task resource. |
taskId | String Required. Task identifier. |
Type | Description |
OperationFuture<Task,OperationMetadata> |
createTaskCallable()
public final UnaryCallable<CreateTaskRequest,Operation> createTaskCallable()
Creates a task resource within a lake.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
CreateTaskRequest request =
CreateTaskRequest.newBuilder()
.setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
.setTaskId("taskId-880873088")
.setTask(Task.newBuilder().build())
.setValidateOnly(true)
.build();
ApiFuture<Operation> future = dataplexServiceClient.createTaskCallable().futureCall(request);
// Do something.
Operation response = future.get();
}
Type | Description |
UnaryCallable<CreateTaskRequest,Operation> |
createTaskOperationCallable()
public final OperationCallable<CreateTaskRequest,Task,OperationMetadata> createTaskOperationCallable()
Creates a task resource within a lake.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
CreateTaskRequest request =
CreateTaskRequest.newBuilder()
.setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
.setTaskId("taskId-880873088")
.setTask(Task.newBuilder().build())
.setValidateOnly(true)
.build();
OperationFuture<Task, OperationMetadata> future =
dataplexServiceClient.createTaskOperationCallable().futureCall(request);
// Do something.
Task response = future.get();
}
Type | Description |
OperationCallable<CreateTaskRequest,Task,OperationMetadata> |
createZoneAsync(CreateZoneRequest request)
public final OperationFuture<Zone,OperationMetadata> createZoneAsync(CreateZoneRequest request)
Creates a zone resource within a lake.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
CreateZoneRequest request =
CreateZoneRequest.newBuilder()
.setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
.setZoneId("zoneId-696323609")
.setZone(Zone.newBuilder().build())
.setValidateOnly(true)
.build();
Zone response = dataplexServiceClient.createZoneAsync(request).get();
}
Name | Description |
request | CreateZoneRequest The request object containing all of the parameters for the API call. |
Type | Description |
OperationFuture<Zone,OperationMetadata> |
createZoneAsync(LakeName parent, Zone zone, String zoneId)
public final OperationFuture<Zone,OperationMetadata> createZoneAsync(LakeName parent, Zone zone, String zoneId)
Creates a zone resource within a lake.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
LakeName parent = LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]");
Zone zone = Zone.newBuilder().build();
String zoneId = "zoneId-696323609";
Zone response = dataplexServiceClient.createZoneAsync(parent, zone, zoneId).get();
}
Name | Description |
parent | LakeName Required. The resource name of the parent lake:
|
zone | Zone Required. Zone resource. |
zoneId | String Required. Zone identifier. This ID will be used to generate names such as database and dataset names when publishing metadata to Hive Metastore and BigQuery.
|
Type | Description |
OperationFuture<Zone,OperationMetadata> |
createZoneAsync(String parent, Zone zone, String zoneId)
public final OperationFuture<Zone,OperationMetadata> createZoneAsync(String parent, Zone zone, String zoneId)
Creates a zone resource within a lake.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
String parent = LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString();
Zone zone = Zone.newBuilder().build();
String zoneId = "zoneId-696323609";
Zone response = dataplexServiceClient.createZoneAsync(parent, zone, zoneId).get();
}
Name | Description |
parent | String Required. The resource name of the parent lake:
|
zone | Zone Required. Zone resource. |
zoneId | String Required. Zone identifier. This ID will be used to generate names such as database and dataset names when publishing metadata to Hive Metastore and BigQuery.
|
Type | Description |
OperationFuture<Zone,OperationMetadata> |
createZoneCallable()
public final UnaryCallable<CreateZoneRequest,Operation> createZoneCallable()
Creates a zone resource within a lake.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
CreateZoneRequest request =
CreateZoneRequest.newBuilder()
.setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
.setZoneId("zoneId-696323609")
.setZone(Zone.newBuilder().build())
.setValidateOnly(true)
.build();
ApiFuture<Operation> future = dataplexServiceClient.createZoneCallable().futureCall(request);
// Do something.
Operation response = future.get();
}
Type | Description |
UnaryCallable<CreateZoneRequest,Operation> |
createZoneOperationCallable()
public final OperationCallable<CreateZoneRequest,Zone,OperationMetadata> createZoneOperationCallable()
Creates a zone resource within a lake.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
CreateZoneRequest request =
CreateZoneRequest.newBuilder()
.setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
.setZoneId("zoneId-696323609")
.setZone(Zone.newBuilder().build())
.setValidateOnly(true)
.build();
OperationFuture<Zone, OperationMetadata> future =
dataplexServiceClient.createZoneOperationCallable().futureCall(request);
// Do something.
Zone response = future.get();
}
Type | Description |
OperationCallable<CreateZoneRequest,Zone,OperationMetadata> |
deleteAssetAsync(AssetName name)
public final OperationFuture<Empty,OperationMetadata> deleteAssetAsync(AssetName name)
Deletes an asset resource. The referenced storage resource is detached (default) or deleted based on the associated Lifecycle policy.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
AssetName name = AssetName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]", "[ASSET]");
dataplexServiceClient.deleteAssetAsync(name).get();
}
Name | Description |
name | AssetName Required. The resource name of the asset:
|
Type | Description |
OperationFuture<Empty,OperationMetadata> |
deleteAssetAsync(DeleteAssetRequest request)
public final OperationFuture<Empty,OperationMetadata> deleteAssetAsync(DeleteAssetRequest request)
Deletes an asset resource. The referenced storage resource is detached (default) or deleted based on the associated Lifecycle policy.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
DeleteAssetRequest request =
DeleteAssetRequest.newBuilder()
.setName(
AssetName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]", "[ASSET]").toString())
.build();
dataplexServiceClient.deleteAssetAsync(request).get();
}
Name | Description |
request | DeleteAssetRequest The request object containing all of the parameters for the API call. |
Type | Description |
OperationFuture<Empty,OperationMetadata> |
deleteAssetAsync(String name)
public final OperationFuture<Empty,OperationMetadata> deleteAssetAsync(String name)
Deletes an asset resource. The referenced storage resource is detached (default) or deleted based on the associated Lifecycle policy.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
String name =
AssetName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]", "[ASSET]").toString();
dataplexServiceClient.deleteAssetAsync(name).get();
}
Name | Description |
name | String Required. The resource name of the asset:
|
Type | Description |
OperationFuture<Empty,OperationMetadata> |
deleteAssetCallable()
public final UnaryCallable<DeleteAssetRequest,Operation> deleteAssetCallable()
Deletes an asset resource. The referenced storage resource is detached (default) or deleted based on the associated Lifecycle policy.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
DeleteAssetRequest request =
DeleteAssetRequest.newBuilder()
.setName(
AssetName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]", "[ASSET]").toString())
.build();
ApiFuture<Operation> future = dataplexServiceClient.deleteAssetCallable().futureCall(request);
// Do something.
future.get();
}
Type | Description |
UnaryCallable<DeleteAssetRequest,Operation> |
deleteAssetOperationCallable()
public final OperationCallable<DeleteAssetRequest,Empty,OperationMetadata> deleteAssetOperationCallable()
Deletes an asset resource. The referenced storage resource is detached (default) or deleted based on the associated Lifecycle policy.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
DeleteAssetRequest request =
DeleteAssetRequest.newBuilder()
.setName(
AssetName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]", "[ASSET]").toString())
.build();
OperationFuture<Empty, OperationMetadata> future =
dataplexServiceClient.deleteAssetOperationCallable().futureCall(request);
// Do something.
future.get();
}
Type | Description |
OperationCallable<DeleteAssetRequest,Empty,OperationMetadata> |
deleteEnvironmentAsync(DeleteEnvironmentRequest request)
public final OperationFuture<Empty,OperationMetadata> deleteEnvironmentAsync(DeleteEnvironmentRequest request)
Delete the environment resource. All the child resources must have been deleted before environment deletion can be initiated.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
DeleteEnvironmentRequest request =
DeleteEnvironmentRequest.newBuilder()
.setName(
EnvironmentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ENVIRONMENT]")
.toString())
.build();
dataplexServiceClient.deleteEnvironmentAsync(request).get();
}
Name | Description |
request | DeleteEnvironmentRequest The request object containing all of the parameters for the API call. |
Type | Description |
OperationFuture<Empty,OperationMetadata> |
deleteEnvironmentAsync(EnvironmentName name)
public final OperationFuture<Empty,OperationMetadata> deleteEnvironmentAsync(EnvironmentName name)
Delete the environment resource. All the child resources must have been deleted before environment deletion can be initiated.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
EnvironmentName name =
EnvironmentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ENVIRONMENT]");
dataplexServiceClient.deleteEnvironmentAsync(name).get();
}
Name | Description |
name | EnvironmentName Required. The resource name of the environment: projects/{project_id}/locations/{location_id}/lakes/{lake_id}/environments/{environment_id}` |
Type | Description |
OperationFuture<Empty,OperationMetadata> |
deleteEnvironmentAsync(String name)
public final OperationFuture<Empty,OperationMetadata> deleteEnvironmentAsync(String name)
Delete the environment resource. All the child resources must have been deleted before environment deletion can be initiated.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
String name =
EnvironmentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ENVIRONMENT]").toString();
dataplexServiceClient.deleteEnvironmentAsync(name).get();
}
Name | Description |
name | String Required. The resource name of the environment: projects/{project_id}/locations/{location_id}/lakes/{lake_id}/environments/{environment_id}` |
Type | Description |
OperationFuture<Empty,OperationMetadata> |
deleteEnvironmentCallable()
public final UnaryCallable<DeleteEnvironmentRequest,Operation> deleteEnvironmentCallable()
Delete the environment resource. All the child resources must have been deleted before environment deletion can be initiated.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
DeleteEnvironmentRequest request =
DeleteEnvironmentRequest.newBuilder()
.setName(
EnvironmentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ENVIRONMENT]")
.toString())
.build();
ApiFuture<Operation> future =
dataplexServiceClient.deleteEnvironmentCallable().futureCall(request);
// Do something.
future.get();
}
Type | Description |
UnaryCallable<DeleteEnvironmentRequest,Operation> |
deleteEnvironmentOperationCallable()
public final OperationCallable<DeleteEnvironmentRequest,Empty,OperationMetadata> deleteEnvironmentOperationCallable()
Delete the environment resource. All the child resources must have been deleted before environment deletion can be initiated.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
DeleteEnvironmentRequest request =
DeleteEnvironmentRequest.newBuilder()
.setName(
EnvironmentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ENVIRONMENT]")
.toString())
.build();
OperationFuture<Empty, OperationMetadata> future =
dataplexServiceClient.deleteEnvironmentOperationCallable().futureCall(request);
// Do something.
future.get();
}
Type | Description |
OperationCallable<DeleteEnvironmentRequest,Empty,OperationMetadata> |
deleteLakeAsync(DeleteLakeRequest request)
public final OperationFuture<Empty,OperationMetadata> deleteLakeAsync(DeleteLakeRequest request)
Deletes a lake resource. All zones within the lake must be deleted before the lake can be deleted.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
DeleteLakeRequest request =
DeleteLakeRequest.newBuilder()
.setName(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
.build();
dataplexServiceClient.deleteLakeAsync(request).get();
}
Name | Description |
request | DeleteLakeRequest The request object containing all of the parameters for the API call. |
Type | Description |
OperationFuture<Empty,OperationMetadata> |
deleteLakeAsync(LakeName name)
public final OperationFuture<Empty,OperationMetadata> deleteLakeAsync(LakeName name)
Deletes a lake resource. All zones within the lake must be deleted before the lake can be deleted.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
LakeName name = LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]");
dataplexServiceClient.deleteLakeAsync(name).get();
}
Name | Description |
name | LakeName Required. The resource name of the lake:
|
Type | Description |
OperationFuture<Empty,OperationMetadata> |
deleteLakeAsync(String name)
public final OperationFuture<Empty,OperationMetadata> deleteLakeAsync(String name)
Deletes a lake resource. All zones within the lake must be deleted before the lake can be deleted.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
String name = LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString();
dataplexServiceClient.deleteLakeAsync(name).get();
}
Name | Description |
name | String Required. The resource name of the lake:
|
Type | Description |
OperationFuture<Empty,OperationMetadata> |
deleteLakeCallable()
public final UnaryCallable<DeleteLakeRequest,Operation> deleteLakeCallable()
Deletes a lake resource. All zones within the lake must be deleted before the lake can be deleted.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
DeleteLakeRequest request =
DeleteLakeRequest.newBuilder()
.setName(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
.build();
ApiFuture<Operation> future = dataplexServiceClient.deleteLakeCallable().futureCall(request);
// Do something.
future.get();
}
Type | Description |
UnaryCallable<DeleteLakeRequest,Operation> |
deleteLakeOperationCallable()
public final OperationCallable<DeleteLakeRequest,Empty,OperationMetadata> deleteLakeOperationCallable()
Deletes a lake resource. All zones within the lake must be deleted before the lake can be deleted.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
DeleteLakeRequest request =
DeleteLakeRequest.newBuilder()
.setName(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
.build();
OperationFuture<Empty, OperationMetadata> future =
dataplexServiceClient.deleteLakeOperationCallable().futureCall(request);
// Do something.
future.get();
}
Type | Description |
OperationCallable<DeleteLakeRequest,Empty,OperationMetadata> |
deleteTaskAsync(DeleteTaskRequest request)
public final OperationFuture<Empty,OperationMetadata> deleteTaskAsync(DeleteTaskRequest request)
Delete the task resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
DeleteTaskRequest request =
DeleteTaskRequest.newBuilder()
.setName(TaskName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[TASK]").toString())
.build();
dataplexServiceClient.deleteTaskAsync(request).get();
}
Name | Description |
request | DeleteTaskRequest The request object containing all of the parameters for the API call. |
Type | Description |
OperationFuture<Empty,OperationMetadata> |
deleteTaskAsync(TaskName name)
public final OperationFuture<Empty,OperationMetadata> deleteTaskAsync(TaskName name)
Delete the task resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
TaskName name = TaskName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[TASK]");
dataplexServiceClient.deleteTaskAsync(name).get();
}
Name | Description |
name | TaskName Required. The resource name of the task:
|
Type | Description |
OperationFuture<Empty,OperationMetadata> |
deleteTaskAsync(String name)
public final OperationFuture<Empty,OperationMetadata> deleteTaskAsync(String name)
Delete the task resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
String name = TaskName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[TASK]").toString();
dataplexServiceClient.deleteTaskAsync(name).get();
}
Name | Description |
name | String Required. The resource name of the task:
|
Type | Description |
OperationFuture<Empty,OperationMetadata> |
deleteTaskCallable()
public final UnaryCallable<DeleteTaskRequest,Operation> deleteTaskCallable()
Delete the task resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
DeleteTaskRequest request =
DeleteTaskRequest.newBuilder()
.setName(TaskName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[TASK]").toString())
.build();
ApiFuture<Operation> future = dataplexServiceClient.deleteTaskCallable().futureCall(request);
// Do something.
future.get();
}
Type | Description |
UnaryCallable<DeleteTaskRequest,Operation> |
deleteTaskOperationCallable()
public final OperationCallable<DeleteTaskRequest,Empty,OperationMetadata> deleteTaskOperationCallable()
Delete the task resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
DeleteTaskRequest request =
DeleteTaskRequest.newBuilder()
.setName(TaskName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[TASK]").toString())
.build();
OperationFuture<Empty, OperationMetadata> future =
dataplexServiceClient.deleteTaskOperationCallable().futureCall(request);
// Do something.
future.get();
}
Type | Description |
OperationCallable<DeleteTaskRequest,Empty,OperationMetadata> |
deleteZoneAsync(DeleteZoneRequest request)
public final OperationFuture<Empty,OperationMetadata> deleteZoneAsync(DeleteZoneRequest request)
Deletes a zone resource. All assets within a zone must be deleted before the zone can be deleted.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
DeleteZoneRequest request =
DeleteZoneRequest.newBuilder()
.setName(ZoneName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]").toString())
.build();
dataplexServiceClient.deleteZoneAsync(request).get();
}
Name | Description |
request | DeleteZoneRequest The request object containing all of the parameters for the API call. |
Type | Description |
OperationFuture<Empty,OperationMetadata> |
deleteZoneAsync(ZoneName name)
public final OperationFuture<Empty,OperationMetadata> deleteZoneAsync(ZoneName name)
Deletes a zone resource. All assets within a zone must be deleted before the zone can be deleted.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ZoneName name = ZoneName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]");
dataplexServiceClient.deleteZoneAsync(name).get();
}
Name | Description |
name | ZoneName Required. The resource name of the zone:
|
Type | Description |
OperationFuture<Empty,OperationMetadata> |
deleteZoneAsync(String name)
public final OperationFuture<Empty,OperationMetadata> deleteZoneAsync(String name)
Deletes a zone resource. All assets within a zone must be deleted before the zone can be deleted.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
String name = ZoneName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]").toString();
dataplexServiceClient.deleteZoneAsync(name).get();
}
Name | Description |
name | String Required. The resource name of the zone:
|
Type | Description |
OperationFuture<Empty,OperationMetadata> |
deleteZoneCallable()
public final UnaryCallable<DeleteZoneRequest,Operation> deleteZoneCallable()
Deletes a zone resource. All assets within a zone must be deleted before the zone can be deleted.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
DeleteZoneRequest request =
DeleteZoneRequest.newBuilder()
.setName(ZoneName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]").toString())
.build();
ApiFuture<Operation> future = dataplexServiceClient.deleteZoneCallable().futureCall(request);
// Do something.
future.get();
}
Type | Description |
UnaryCallable<DeleteZoneRequest,Operation> |
deleteZoneOperationCallable()
public final OperationCallable<DeleteZoneRequest,Empty,OperationMetadata> deleteZoneOperationCallable()
Deletes a zone resource. All assets within a zone must be deleted before the zone can be deleted.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
DeleteZoneRequest request =
DeleteZoneRequest.newBuilder()
.setName(ZoneName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]").toString())
.build();
OperationFuture<Empty, OperationMetadata> future =
dataplexServiceClient.deleteZoneOperationCallable().futureCall(request);
// Do something.
future.get();
}
Type | Description |
OperationCallable<DeleteZoneRequest,Empty,OperationMetadata> |
getAsset(AssetName name)
public final Asset getAsset(AssetName name)
Retrieves an asset resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
AssetName name = AssetName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]", "[ASSET]");
Asset response = dataplexServiceClient.getAsset(name);
}
Name | Description |
name | AssetName Required. The resource name of the asset:
|
Type | Description |
Asset |
getAsset(GetAssetRequest request)
public final Asset getAsset(GetAssetRequest request)
Retrieves an asset resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
GetAssetRequest request =
GetAssetRequest.newBuilder()
.setName(
AssetName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]", "[ASSET]").toString())
.build();
Asset response = dataplexServiceClient.getAsset(request);
}
Name | Description |
request | GetAssetRequest The request object containing all of the parameters for the API call. |
Type | Description |
Asset |
getAsset(String name)
public final Asset getAsset(String name)
Retrieves an asset resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
String name =
AssetName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]", "[ASSET]").toString();
Asset response = dataplexServiceClient.getAsset(name);
}
Name | Description |
name | String Required. The resource name of the asset:
|
Type | Description |
Asset |
getAssetCallable()
public final UnaryCallable<GetAssetRequest,Asset> getAssetCallable()
Retrieves an asset resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
GetAssetRequest request =
GetAssetRequest.newBuilder()
.setName(
AssetName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]", "[ASSET]").toString())
.build();
ApiFuture<Asset> future = dataplexServiceClient.getAssetCallable().futureCall(request);
// Do something.
Asset response = future.get();
}
Type | Description |
UnaryCallable<GetAssetRequest,Asset> |
getEnvironment(EnvironmentName name)
public final Environment getEnvironment(EnvironmentName name)
Get environment resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
EnvironmentName name =
EnvironmentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ENVIRONMENT]");
Environment response = dataplexServiceClient.getEnvironment(name);
}
Name | Description |
name | EnvironmentName Required. The resource name of the environment: projects/{project_id}/locations/{location_id}/lakes/{lake_id}/environments/{environment_id} |
Type | Description |
Environment |
getEnvironment(GetEnvironmentRequest request)
public final Environment getEnvironment(GetEnvironmentRequest request)
Get environment resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
GetEnvironmentRequest request =
GetEnvironmentRequest.newBuilder()
.setName(
EnvironmentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ENVIRONMENT]")
.toString())
.build();
Environment response = dataplexServiceClient.getEnvironment(request);
}
Name | Description |
request | GetEnvironmentRequest The request object containing all of the parameters for the API call. |
Type | Description |
Environment |
getEnvironment(String name)
public final Environment getEnvironment(String name)
Get environment resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
String name =
EnvironmentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ENVIRONMENT]").toString();
Environment response = dataplexServiceClient.getEnvironment(name);
}
Name | Description |
name | String Required. The resource name of the environment: projects/{project_id}/locations/{location_id}/lakes/{lake_id}/environments/{environment_id} |
Type | Description |
Environment |
getEnvironmentCallable()
public final UnaryCallable<GetEnvironmentRequest,Environment> getEnvironmentCallable()
Get environment resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
GetEnvironmentRequest request =
GetEnvironmentRequest.newBuilder()
.setName(
EnvironmentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ENVIRONMENT]")
.toString())
.build();
ApiFuture<Environment> future =
dataplexServiceClient.getEnvironmentCallable().futureCall(request);
// Do something.
Environment response = future.get();
}
Type | Description |
UnaryCallable<GetEnvironmentRequest,Environment> |
getJob(GetJobRequest request)
public final Job getJob(GetJobRequest request)
Get job resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
GetJobRequest request =
GetJobRequest.newBuilder()
.setName(
JobName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[TASK]", "[JOB]").toString())
.build();
Job response = dataplexServiceClient.getJob(request);
}
Name | Description |
request | GetJobRequest The request object containing all of the parameters for the API call. |
Type | Description |
Job |
getJob(JobName name)
public final Job getJob(JobName name)
Get job resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[TASK]", "[JOB]");
Job response = dataplexServiceClient.getJob(name);
}
Name | Description |
name | JobName Required. The resource name of the job:
|
Type | Description |
Job |
getJob(String name)
public final Job getJob(String name)
Get job resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
String name = JobName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[TASK]", "[JOB]").toString();
Job response = dataplexServiceClient.getJob(name);
}
Name | Description |
name | String Required. The resource name of the job:
|
Type | Description |
Job |
getJobCallable()
public final UnaryCallable<GetJobRequest,Job> getJobCallable()
Get job resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
GetJobRequest request =
GetJobRequest.newBuilder()
.setName(
JobName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[TASK]", "[JOB]").toString())
.build();
ApiFuture<Job> future = dataplexServiceClient.getJobCallable().futureCall(request);
// Do something.
Job response = future.get();
}
Type | Description |
UnaryCallable<GetJobRequest,Job> |
getLake(GetLakeRequest request)
public final Lake getLake(GetLakeRequest request)
Retrieves a lake resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
GetLakeRequest request =
GetLakeRequest.newBuilder()
.setName(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
.build();
Lake response = dataplexServiceClient.getLake(request);
}
Name | Description |
request | GetLakeRequest The request object containing all of the parameters for the API call. |
Type | Description |
Lake |
getLake(LakeName name)
public final Lake getLake(LakeName name)
Retrieves a lake resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
LakeName name = LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]");
Lake response = dataplexServiceClient.getLake(name);
}
Name | Description |
name | LakeName Required. The resource name of the lake:
|
Type | Description |
Lake |
getLake(String name)
public final Lake getLake(String name)
Retrieves a lake resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
String name = LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString();
Lake response = dataplexServiceClient.getLake(name);
}
Name | Description |
name | String Required. The resource name of the lake:
|
Type | Description |
Lake |
getLakeCallable()
public final UnaryCallable<GetLakeRequest,Lake> getLakeCallable()
Retrieves a lake resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
GetLakeRequest request =
GetLakeRequest.newBuilder()
.setName(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
.build();
ApiFuture<Lake> future = dataplexServiceClient.getLakeCallable().futureCall(request);
// Do something.
Lake response = future.get();
}
Type | Description |
UnaryCallable<GetLakeRequest,Lake> |
getOperationsClient()
public final OperationsClient getOperationsClient()
Returns the OperationsClient that can be used to query the status of a long-running operation returned by another API method call.
Type | Description |
OperationsClient |
getSettings()
public final DataplexServiceSettings getSettings()
Type | Description |
DataplexServiceSettings |
getStub()
public DataplexServiceStub getStub()
Type | Description |
DataplexServiceStub |
getTask(GetTaskRequest request)
public final Task getTask(GetTaskRequest request)
Get task resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
GetTaskRequest request =
GetTaskRequest.newBuilder()
.setName(TaskName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[TASK]").toString())
.build();
Task response = dataplexServiceClient.getTask(request);
}
Name | Description |
request | GetTaskRequest The request object containing all of the parameters for the API call. |
Type | Description |
Task |
getTask(TaskName name)
public final Task getTask(TaskName name)
Get task resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
TaskName name = TaskName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[TASK]");
Task response = dataplexServiceClient.getTask(name);
}
Name | Description |
name | TaskName Required. The resource name of the task:
|
Type | Description |
Task |
getTask(String name)
public final Task getTask(String name)
Get task resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
String name = TaskName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[TASK]").toString();
Task response = dataplexServiceClient.getTask(name);
}
Name | Description |
name | String Required. The resource name of the task:
|
Type | Description |
Task |
getTaskCallable()
public final UnaryCallable<GetTaskRequest,Task> getTaskCallable()
Get task resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
GetTaskRequest request =
GetTaskRequest.newBuilder()
.setName(TaskName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[TASK]").toString())
.build();
ApiFuture<Task> future = dataplexServiceClient.getTaskCallable().futureCall(request);
// Do something.
Task response = future.get();
}
Type | Description |
UnaryCallable<GetTaskRequest,Task> |
getZone(GetZoneRequest request)
public final Zone getZone(GetZoneRequest request)
Retrieves a zone resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
GetZoneRequest request =
GetZoneRequest.newBuilder()
.setName(ZoneName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]").toString())
.build();
Zone response = dataplexServiceClient.getZone(request);
}
Name | Description |
request | GetZoneRequest The request object containing all of the parameters for the API call. |
Type | Description |
Zone |
getZone(ZoneName name)
public final Zone getZone(ZoneName name)
Retrieves a zone resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ZoneName name = ZoneName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]");
Zone response = dataplexServiceClient.getZone(name);
}
Name | Description |
name | ZoneName Required. The resource name of the zone:
|
Type | Description |
Zone |
getZone(String name)
public final Zone getZone(String name)
Retrieves a zone resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
String name = ZoneName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]").toString();
Zone response = dataplexServiceClient.getZone(name);
}
Name | Description |
name | String Required. The resource name of the zone:
|
Type | Description |
Zone |
getZoneCallable()
public final UnaryCallable<GetZoneRequest,Zone> getZoneCallable()
Retrieves a zone resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
GetZoneRequest request =
GetZoneRequest.newBuilder()
.setName(ZoneName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]").toString())
.build();
ApiFuture<Zone> future = dataplexServiceClient.getZoneCallable().futureCall(request);
// Do something.
Zone response = future.get();
}
Type | Description |
UnaryCallable<GetZoneRequest,Zone> |
isShutdown()
public boolean isShutdown()
Type | Description |
boolean |
isTerminated()
public boolean isTerminated()
Type | Description |
boolean |
listAssetActions(AssetName parent)
public final DataplexServiceClient.ListAssetActionsPagedResponse listAssetActions(AssetName parent)
Lists action resources in an asset.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
AssetName parent = AssetName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]", "[ASSET]");
for (Action element : dataplexServiceClient.listAssetActions(parent).iterateAll()) {
// doThingsWith(element);
}
}
Name | Description |
parent | AssetName Required. The resource name of the parent asset:
|
Type | Description |
DataplexServiceClient.ListAssetActionsPagedResponse |
listAssetActions(ListAssetActionsRequest request)
public final DataplexServiceClient.ListAssetActionsPagedResponse listAssetActions(ListAssetActionsRequest request)
Lists action resources in an asset.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ListAssetActionsRequest request =
ListAssetActionsRequest.newBuilder()
.setParent(
AssetName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]", "[ASSET]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.build();
for (Action element : dataplexServiceClient.listAssetActions(request).iterateAll()) {
// doThingsWith(element);
}
}
Name | Description |
request | ListAssetActionsRequest The request object containing all of the parameters for the API call. |
Type | Description |
DataplexServiceClient.ListAssetActionsPagedResponse |
listAssetActions(String parent)
public final DataplexServiceClient.ListAssetActionsPagedResponse listAssetActions(String parent)
Lists action resources in an asset.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
String parent =
AssetName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]", "[ASSET]").toString();
for (Action element : dataplexServiceClient.listAssetActions(parent).iterateAll()) {
// doThingsWith(element);
}
}
Name | Description |
parent | String Required. The resource name of the parent asset:
|
Type | Description |
DataplexServiceClient.ListAssetActionsPagedResponse |
listAssetActionsCallable()
public final UnaryCallable<ListAssetActionsRequest,ListActionsResponse> listAssetActionsCallable()
Lists action resources in an asset.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ListAssetActionsRequest request =
ListAssetActionsRequest.newBuilder()
.setParent(
AssetName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]", "[ASSET]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.build();
while (true) {
ListActionsResponse response =
dataplexServiceClient.listAssetActionsCallable().call(request);
for (Action element : response.getActionsList()) {
// doThingsWith(element);
}
String nextPageToken = response.getNextPageToken();
if (!Strings.isNullOrEmpty(nextPageToken)) {
request = request.toBuilder().setPageToken(nextPageToken).build();
} else {
break;
}
}
}
Type | Description |
UnaryCallable<ListAssetActionsRequest,ListActionsResponse> |
listAssetActionsPagedCallable()
public final UnaryCallable<ListAssetActionsRequest,DataplexServiceClient.ListAssetActionsPagedResponse> listAssetActionsPagedCallable()
Lists action resources in an asset.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ListAssetActionsRequest request =
ListAssetActionsRequest.newBuilder()
.setParent(
AssetName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]", "[ASSET]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.build();
ApiFuture<Action> future =
dataplexServiceClient.listAssetActionsPagedCallable().futureCall(request);
// Do something.
for (Action element : future.get().iterateAll()) {
// doThingsWith(element);
}
}
Type | Description |
UnaryCallable<ListAssetActionsRequest,ListAssetActionsPagedResponse> |
listAssets(ListAssetsRequest request)
public final DataplexServiceClient.ListAssetsPagedResponse listAssets(ListAssetsRequest request)
Lists asset resources in a zone.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ListAssetsRequest request =
ListAssetsRequest.newBuilder()
.setParent(ZoneName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.setFilter("filter-1274492040")
.setOrderBy("orderBy-1207110587")
.build();
for (Asset element : dataplexServiceClient.listAssets(request).iterateAll()) {
// doThingsWith(element);
}
}
Name | Description |
request | ListAssetsRequest The request object containing all of the parameters for the API call. |
Type | Description |
DataplexServiceClient.ListAssetsPagedResponse |
listAssets(ZoneName parent)
public final DataplexServiceClient.ListAssetsPagedResponse listAssets(ZoneName parent)
Lists asset resources in a zone.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ZoneName parent = ZoneName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]");
for (Asset element : dataplexServiceClient.listAssets(parent).iterateAll()) {
// doThingsWith(element);
}
}
Name | Description |
parent | ZoneName Required. The resource name of the parent zone:
|
Type | Description |
DataplexServiceClient.ListAssetsPagedResponse |
listAssets(String parent)
public final DataplexServiceClient.ListAssetsPagedResponse listAssets(String parent)
Lists asset resources in a zone.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
String parent = ZoneName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]").toString();
for (Asset element : dataplexServiceClient.listAssets(parent).iterateAll()) {
// doThingsWith(element);
}
}
Name | Description |
parent | String Required. The resource name of the parent zone:
|
Type | Description |
DataplexServiceClient.ListAssetsPagedResponse |
listAssetsCallable()
public final UnaryCallable<ListAssetsRequest,ListAssetsResponse> listAssetsCallable()
Lists asset resources in a zone.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ListAssetsRequest request =
ListAssetsRequest.newBuilder()
.setParent(ZoneName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.setFilter("filter-1274492040")
.setOrderBy("orderBy-1207110587")
.build();
while (true) {
ListAssetsResponse response = dataplexServiceClient.listAssetsCallable().call(request);
for (Asset element : response.getAssetsList()) {
// doThingsWith(element);
}
String nextPageToken = response.getNextPageToken();
if (!Strings.isNullOrEmpty(nextPageToken)) {
request = request.toBuilder().setPageToken(nextPageToken).build();
} else {
break;
}
}
}
Type | Description |
UnaryCallable<ListAssetsRequest,ListAssetsResponse> |
listAssetsPagedCallable()
public final UnaryCallable<ListAssetsRequest,DataplexServiceClient.ListAssetsPagedResponse> listAssetsPagedCallable()
Lists asset resources in a zone.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ListAssetsRequest request =
ListAssetsRequest.newBuilder()
.setParent(ZoneName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.setFilter("filter-1274492040")
.setOrderBy("orderBy-1207110587")
.build();
ApiFuture<Asset> future = dataplexServiceClient.listAssetsPagedCallable().futureCall(request);
// Do something.
for (Asset element : future.get().iterateAll()) {
// doThingsWith(element);
}
}
Type | Description |
UnaryCallable<ListAssetsRequest,ListAssetsPagedResponse> |
listEnvironments(LakeName parent)
public final DataplexServiceClient.ListEnvironmentsPagedResponse listEnvironments(LakeName parent)
Lists environments under the given lake.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
LakeName parent = LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]");
for (Environment element : dataplexServiceClient.listEnvironments(parent).iterateAll()) {
// doThingsWith(element);
}
}
Name | Description |
parent | LakeName Required. The resource name of the parent lake: projects/{project_id}/locations/{location_id}/lakes/{lake_id} |
Type | Description |
DataplexServiceClient.ListEnvironmentsPagedResponse |
listEnvironments(ListEnvironmentsRequest request)
public final DataplexServiceClient.ListEnvironmentsPagedResponse listEnvironments(ListEnvironmentsRequest request)
Lists environments under the given lake.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ListEnvironmentsRequest request =
ListEnvironmentsRequest.newBuilder()
.setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.setFilter("filter-1274492040")
.setOrderBy("orderBy-1207110587")
.build();
for (Environment element : dataplexServiceClient.listEnvironments(request).iterateAll()) {
// doThingsWith(element);
}
}
Name | Description |
request | ListEnvironmentsRequest The request object containing all of the parameters for the API call. |
Type | Description |
DataplexServiceClient.ListEnvironmentsPagedResponse |
listEnvironments(String parent)
public final DataplexServiceClient.ListEnvironmentsPagedResponse listEnvironments(String parent)
Lists environments under the given lake.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
String parent = LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString();
for (Environment element : dataplexServiceClient.listEnvironments(parent).iterateAll()) {
// doThingsWith(element);
}
}
Name | Description |
parent | String Required. The resource name of the parent lake: projects/{project_id}/locations/{location_id}/lakes/{lake_id} |
Type | Description |
DataplexServiceClient.ListEnvironmentsPagedResponse |
listEnvironmentsCallable()
public final UnaryCallable<ListEnvironmentsRequest,ListEnvironmentsResponse> listEnvironmentsCallable()
Lists environments under the given lake.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ListEnvironmentsRequest request =
ListEnvironmentsRequest.newBuilder()
.setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.setFilter("filter-1274492040")
.setOrderBy("orderBy-1207110587")
.build();
while (true) {
ListEnvironmentsResponse response =
dataplexServiceClient.listEnvironmentsCallable().call(request);
for (Environment element : response.getEnvironmentsList()) {
// doThingsWith(element);
}
String nextPageToken = response.getNextPageToken();
if (!Strings.isNullOrEmpty(nextPageToken)) {
request = request.toBuilder().setPageToken(nextPageToken).build();
} else {
break;
}
}
}
Type | Description |
UnaryCallable<ListEnvironmentsRequest,ListEnvironmentsResponse> |
listEnvironmentsPagedCallable()
public final UnaryCallable<ListEnvironmentsRequest,DataplexServiceClient.ListEnvironmentsPagedResponse> listEnvironmentsPagedCallable()
Lists environments under the given lake.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ListEnvironmentsRequest request =
ListEnvironmentsRequest.newBuilder()
.setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.setFilter("filter-1274492040")
.setOrderBy("orderBy-1207110587")
.build();
ApiFuture<Environment> future =
dataplexServiceClient.listEnvironmentsPagedCallable().futureCall(request);
// Do something.
for (Environment element : future.get().iterateAll()) {
// doThingsWith(element);
}
}
Type | Description |
UnaryCallable<ListEnvironmentsRequest,ListEnvironmentsPagedResponse> |
listJobs(ListJobsRequest request)
public final DataplexServiceClient.ListJobsPagedResponse listJobs(ListJobsRequest request)
Lists Jobs under the given task.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ListJobsRequest request =
ListJobsRequest.newBuilder()
.setParent(TaskName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[TASK]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.build();
for (Job element : dataplexServiceClient.listJobs(request).iterateAll()) {
// doThingsWith(element);
}
}
Name | Description |
request | ListJobsRequest The request object containing all of the parameters for the API call. |
Type | Description |
DataplexServiceClient.ListJobsPagedResponse |
listJobs(TaskName parent)
public final DataplexServiceClient.ListJobsPagedResponse listJobs(TaskName parent)
Lists Jobs under the given task.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
TaskName parent = TaskName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[TASK]");
for (Job element : dataplexServiceClient.listJobs(parent).iterateAll()) {
// doThingsWith(element);
}
}
Name | Description |
parent | TaskName Required. The resource name of the parent environment:
|
Type | Description |
DataplexServiceClient.ListJobsPagedResponse |
listJobs(String parent)
public final DataplexServiceClient.ListJobsPagedResponse listJobs(String parent)
Lists Jobs under the given task.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
String parent = TaskName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[TASK]").toString();
for (Job element : dataplexServiceClient.listJobs(parent).iterateAll()) {
// doThingsWith(element);
}
}
Name | Description |
parent | String Required. The resource name of the parent environment:
|
Type | Description |
DataplexServiceClient.ListJobsPagedResponse |
listJobsCallable()
public final UnaryCallable<ListJobsRequest,ListJobsResponse> listJobsCallable()
Lists Jobs under the given task.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ListJobsRequest request =
ListJobsRequest.newBuilder()
.setParent(TaskName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[TASK]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.build();
while (true) {
ListJobsResponse response = dataplexServiceClient.listJobsCallable().call(request);
for (Job element : response.getJobsList()) {
// doThingsWith(element);
}
String nextPageToken = response.getNextPageToken();
if (!Strings.isNullOrEmpty(nextPageToken)) {
request = request.toBuilder().setPageToken(nextPageToken).build();
} else {
break;
}
}
}
Type | Description |
UnaryCallable<ListJobsRequest,ListJobsResponse> |
listJobsPagedCallable()
public final UnaryCallable<ListJobsRequest,DataplexServiceClient.ListJobsPagedResponse> listJobsPagedCallable()
Lists Jobs under the given task.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ListJobsRequest request =
ListJobsRequest.newBuilder()
.setParent(TaskName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[TASK]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.build();
ApiFuture<Job> future = dataplexServiceClient.listJobsPagedCallable().futureCall(request);
// Do something.
for (Job element : future.get().iterateAll()) {
// doThingsWith(element);
}
}
Type | Description |
UnaryCallable<ListJobsRequest,ListJobsPagedResponse> |
listLakeActions(LakeName parent)
public final DataplexServiceClient.ListLakeActionsPagedResponse listLakeActions(LakeName parent)
Lists action resources in a lake.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
LakeName parent = LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]");
for (Action element : dataplexServiceClient.listLakeActions(parent).iterateAll()) {
// doThingsWith(element);
}
}
Name | Description |
parent | LakeName Required. The resource name of the parent lake:
|
Type | Description |
DataplexServiceClient.ListLakeActionsPagedResponse |
listLakeActions(ListLakeActionsRequest request)
public final DataplexServiceClient.ListLakeActionsPagedResponse listLakeActions(ListLakeActionsRequest request)
Lists action resources in a lake.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ListLakeActionsRequest request =
ListLakeActionsRequest.newBuilder()
.setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.build();
for (Action element : dataplexServiceClient.listLakeActions(request).iterateAll()) {
// doThingsWith(element);
}
}
Name | Description |
request | ListLakeActionsRequest The request object containing all of the parameters for the API call. |
Type | Description |
DataplexServiceClient.ListLakeActionsPagedResponse |
listLakeActions(String parent)
public final DataplexServiceClient.ListLakeActionsPagedResponse listLakeActions(String parent)
Lists action resources in a lake.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
String parent = LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString();
for (Action element : dataplexServiceClient.listLakeActions(parent).iterateAll()) {
// doThingsWith(element);
}
}
Name | Description |
parent | String Required. The resource name of the parent lake:
|
Type | Description |
DataplexServiceClient.ListLakeActionsPagedResponse |
listLakeActionsCallable()
public final UnaryCallable<ListLakeActionsRequest,ListActionsResponse> listLakeActionsCallable()
Lists action resources in a lake.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ListLakeActionsRequest request =
ListLakeActionsRequest.newBuilder()
.setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.build();
while (true) {
ListActionsResponse response =
dataplexServiceClient.listLakeActionsCallable().call(request);
for (Action element : response.getActionsList()) {
// doThingsWith(element);
}
String nextPageToken = response.getNextPageToken();
if (!Strings.isNullOrEmpty(nextPageToken)) {
request = request.toBuilder().setPageToken(nextPageToken).build();
} else {
break;
}
}
}
Type | Description |
UnaryCallable<ListLakeActionsRequest,ListActionsResponse> |
listLakeActionsPagedCallable()
public final UnaryCallable<ListLakeActionsRequest,DataplexServiceClient.ListLakeActionsPagedResponse> listLakeActionsPagedCallable()
Lists action resources in a lake.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ListLakeActionsRequest request =
ListLakeActionsRequest.newBuilder()
.setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.build();
ApiFuture<Action> future =
dataplexServiceClient.listLakeActionsPagedCallable().futureCall(request);
// Do something.
for (Action element : future.get().iterateAll()) {
// doThingsWith(element);
}
}
Type | Description |
UnaryCallable<ListLakeActionsRequest,ListLakeActionsPagedResponse> |
listLakes(ListLakesRequest request)
public final DataplexServiceClient.ListLakesPagedResponse listLakes(ListLakesRequest request)
Lists lake resources in a project and location.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ListLakesRequest request =
ListLakesRequest.newBuilder()
.setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.setFilter("filter-1274492040")
.setOrderBy("orderBy-1207110587")
.build();
for (Lake element : dataplexServiceClient.listLakes(request).iterateAll()) {
// doThingsWith(element);
}
}
Name | Description |
request | ListLakesRequest The request object containing all of the parameters for the API call. |
Type | Description |
DataplexServiceClient.ListLakesPagedResponse |
listLakes(LocationName parent)
public final DataplexServiceClient.ListLakesPagedResponse listLakes(LocationName parent)
Lists lake resources in a project and location.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
for (Lake element : dataplexServiceClient.listLakes(parent).iterateAll()) {
// doThingsWith(element);
}
}
Name | Description |
parent | LocationName Required. The resource name of the lake location, of the form:
|
Type | Description |
DataplexServiceClient.ListLakesPagedResponse |
listLakes(String parent)
public final DataplexServiceClient.ListLakesPagedResponse listLakes(String parent)
Lists lake resources in a project and location.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
for (Lake element : dataplexServiceClient.listLakes(parent).iterateAll()) {
// doThingsWith(element);
}
}
Name | Description |
parent | String Required. The resource name of the lake location, of the form:
|
Type | Description |
DataplexServiceClient.ListLakesPagedResponse |
listLakesCallable()
public final UnaryCallable<ListLakesRequest,ListLakesResponse> listLakesCallable()
Lists lake resources in a project and location.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ListLakesRequest request =
ListLakesRequest.newBuilder()
.setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.setFilter("filter-1274492040")
.setOrderBy("orderBy-1207110587")
.build();
while (true) {
ListLakesResponse response = dataplexServiceClient.listLakesCallable().call(request);
for (Lake element : response.getLakesList()) {
// doThingsWith(element);
}
String nextPageToken = response.getNextPageToken();
if (!Strings.isNullOrEmpty(nextPageToken)) {
request = request.toBuilder().setPageToken(nextPageToken).build();
} else {
break;
}
}
}
Type | Description |
UnaryCallable<ListLakesRequest,ListLakesResponse> |
listLakesPagedCallable()
public final UnaryCallable<ListLakesRequest,DataplexServiceClient.ListLakesPagedResponse> listLakesPagedCallable()
Lists lake resources in a project and location.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ListLakesRequest request =
ListLakesRequest.newBuilder()
.setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.setFilter("filter-1274492040")
.setOrderBy("orderBy-1207110587")
.build();
ApiFuture<Lake> future = dataplexServiceClient.listLakesPagedCallable().futureCall(request);
// Do something.
for (Lake element : future.get().iterateAll()) {
// doThingsWith(element);
}
}
Type | Description |
UnaryCallable<ListLakesRequest,ListLakesPagedResponse> |
listSessions(EnvironmentName parent)
public final DataplexServiceClient.ListSessionsPagedResponse listSessions(EnvironmentName parent)
Lists session resources in an environment.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
EnvironmentName parent =
EnvironmentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ENVIRONMENT]");
for (Session element : dataplexServiceClient.listSessions(parent).iterateAll()) {
// doThingsWith(element);
}
}
Name | Description |
parent | EnvironmentName Required. The resource name of the parent environment: projects/{project_number}/locations/{location_id}/lakes/{lake_id}/environment/{environment_id} |
Type | Description |
DataplexServiceClient.ListSessionsPagedResponse |
listSessions(ListSessionsRequest request)
public final DataplexServiceClient.ListSessionsPagedResponse listSessions(ListSessionsRequest request)
Lists session resources in an environment.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ListSessionsRequest request =
ListSessionsRequest.newBuilder()
.setParent(
EnvironmentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ENVIRONMENT]")
.toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.build();
for (Session element : dataplexServiceClient.listSessions(request).iterateAll()) {
// doThingsWith(element);
}
}
Name | Description |
request | ListSessionsRequest The request object containing all of the parameters for the API call. |
Type | Description |
DataplexServiceClient.ListSessionsPagedResponse |
listSessions(String parent)
public final DataplexServiceClient.ListSessionsPagedResponse listSessions(String parent)
Lists session resources in an environment.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
String parent =
EnvironmentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ENVIRONMENT]").toString();
for (Session element : dataplexServiceClient.listSessions(parent).iterateAll()) {
// doThingsWith(element);
}
}
Name | Description |
parent | String Required. The resource name of the parent environment: projects/{project_number}/locations/{location_id}/lakes/{lake_id}/environment/{environment_id} |
Type | Description |
DataplexServiceClient.ListSessionsPagedResponse |
listSessionsCallable()
public final UnaryCallable<ListSessionsRequest,ListSessionsResponse> listSessionsCallable()
Lists session resources in an environment.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ListSessionsRequest request =
ListSessionsRequest.newBuilder()
.setParent(
EnvironmentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ENVIRONMENT]")
.toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.build();
while (true) {
ListSessionsResponse response = dataplexServiceClient.listSessionsCallable().call(request);
for (Session element : response.getSessionsList()) {
// doThingsWith(element);
}
String nextPageToken = response.getNextPageToken();
if (!Strings.isNullOrEmpty(nextPageToken)) {
request = request.toBuilder().setPageToken(nextPageToken).build();
} else {
break;
}
}
}
Type | Description |
UnaryCallable<ListSessionsRequest,ListSessionsResponse> |
listSessionsPagedCallable()
public final UnaryCallable<ListSessionsRequest,DataplexServiceClient.ListSessionsPagedResponse> listSessionsPagedCallable()
Lists session resources in an environment.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ListSessionsRequest request =
ListSessionsRequest.newBuilder()
.setParent(
EnvironmentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ENVIRONMENT]")
.toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.build();
ApiFuture<Session> future =
dataplexServiceClient.listSessionsPagedCallable().futureCall(request);
// Do something.
for (Session element : future.get().iterateAll()) {
// doThingsWith(element);
}
}
Type | Description |
UnaryCallable<ListSessionsRequest,ListSessionsPagedResponse> |
listTasks(LakeName parent)
public final DataplexServiceClient.ListTasksPagedResponse listTasks(LakeName parent)
Lists tasks under the given lake.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
LakeName parent = LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]");
for (Task element : dataplexServiceClient.listTasks(parent).iterateAll()) {
// doThingsWith(element);
}
}
Name | Description |
parent | LakeName Required. The resource name of the parent lake:
|
Type | Description |
DataplexServiceClient.ListTasksPagedResponse |
listTasks(ListTasksRequest request)
public final DataplexServiceClient.ListTasksPagedResponse listTasks(ListTasksRequest request)
Lists tasks under the given lake.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ListTasksRequest request =
ListTasksRequest.newBuilder()
.setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.setFilter("filter-1274492040")
.setOrderBy("orderBy-1207110587")
.build();
for (Task element : dataplexServiceClient.listTasks(request).iterateAll()) {
// doThingsWith(element);
}
}
Name | Description |
request | ListTasksRequest The request object containing all of the parameters for the API call. |
Type | Description |
DataplexServiceClient.ListTasksPagedResponse |
listTasks(String parent)
public final DataplexServiceClient.ListTasksPagedResponse listTasks(String parent)
Lists tasks under the given lake.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
String parent = LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString();
for (Task element : dataplexServiceClient.listTasks(parent).iterateAll()) {
// doThingsWith(element);
}
}
Name | Description |
parent | String Required. The resource name of the parent lake:
|
Type | Description |
DataplexServiceClient.ListTasksPagedResponse |
listTasksCallable()
public final UnaryCallable<ListTasksRequest,ListTasksResponse> listTasksCallable()
Lists tasks under the given lake.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ListTasksRequest request =
ListTasksRequest.newBuilder()
.setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.setFilter("filter-1274492040")
.setOrderBy("orderBy-1207110587")
.build();
while (true) {
ListTasksResponse response = dataplexServiceClient.listTasksCallable().call(request);
for (Task element : response.getTasksList()) {
// doThingsWith(element);
}
String nextPageToken = response.getNextPageToken();
if (!Strings.isNullOrEmpty(nextPageToken)) {
request = request.toBuilder().setPageToken(nextPageToken).build();
} else {
break;
}
}
}
Type | Description |
UnaryCallable<ListTasksRequest,ListTasksResponse> |
listTasksPagedCallable()
public final UnaryCallable<ListTasksRequest,DataplexServiceClient.ListTasksPagedResponse> listTasksPagedCallable()
Lists tasks under the given lake.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ListTasksRequest request =
ListTasksRequest.newBuilder()
.setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.setFilter("filter-1274492040")
.setOrderBy("orderBy-1207110587")
.build();
ApiFuture<Task> future = dataplexServiceClient.listTasksPagedCallable().futureCall(request);
// Do something.
for (Task element : future.get().iterateAll()) {
// doThingsWith(element);
}
}
Type | Description |
UnaryCallable<ListTasksRequest,ListTasksPagedResponse> |
listZoneActions(ListZoneActionsRequest request)
public final DataplexServiceClient.ListZoneActionsPagedResponse listZoneActions(ListZoneActionsRequest request)
Lists action resources in a zone.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ListZoneActionsRequest request =
ListZoneActionsRequest.newBuilder()
.setParent(ZoneName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.build();
for (Action element : dataplexServiceClient.listZoneActions(request).iterateAll()) {
// doThingsWith(element);
}
}
Name | Description |
request | ListZoneActionsRequest The request object containing all of the parameters for the API call. |
Type | Description |
DataplexServiceClient.ListZoneActionsPagedResponse |
listZoneActions(ZoneName parent)
public final DataplexServiceClient.ListZoneActionsPagedResponse listZoneActions(ZoneName parent)
Lists action resources in a zone.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ZoneName parent = ZoneName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]");
for (Action element : dataplexServiceClient.listZoneActions(parent).iterateAll()) {
// doThingsWith(element);
}
}
Name | Description |
parent | ZoneName Required. The resource name of the parent zone:
|
Type | Description |
DataplexServiceClient.ListZoneActionsPagedResponse |
listZoneActions(String parent)
public final DataplexServiceClient.ListZoneActionsPagedResponse listZoneActions(String parent)
Lists action resources in a zone.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
String parent = ZoneName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]").toString();
for (Action element : dataplexServiceClient.listZoneActions(parent).iterateAll()) {
// doThingsWith(element);
}
}
Name | Description |
parent | String Required. The resource name of the parent zone:
|
Type | Description |
DataplexServiceClient.ListZoneActionsPagedResponse |
listZoneActionsCallable()
public final UnaryCallable<ListZoneActionsRequest,ListActionsResponse> listZoneActionsCallable()
Lists action resources in a zone.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ListZoneActionsRequest request =
ListZoneActionsRequest.newBuilder()
.setParent(ZoneName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.build();
while (true) {
ListActionsResponse response =
dataplexServiceClient.listZoneActionsCallable().call(request);
for (Action element : response.getActionsList()) {
// doThingsWith(element);
}
String nextPageToken = response.getNextPageToken();
if (!Strings.isNullOrEmpty(nextPageToken)) {
request = request.toBuilder().setPageToken(nextPageToken).build();
} else {
break;
}
}
}
Type | Description |
UnaryCallable<ListZoneActionsRequest,ListActionsResponse> |
listZoneActionsPagedCallable()
public final UnaryCallable<ListZoneActionsRequest,DataplexServiceClient.ListZoneActionsPagedResponse> listZoneActionsPagedCallable()
Lists action resources in a zone.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ListZoneActionsRequest request =
ListZoneActionsRequest.newBuilder()
.setParent(ZoneName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.build();
ApiFuture<Action> future =
dataplexServiceClient.listZoneActionsPagedCallable().futureCall(request);
// Do something.
for (Action element : future.get().iterateAll()) {
// doThingsWith(element);
}
}
Type | Description |
UnaryCallable<ListZoneActionsRequest,ListZoneActionsPagedResponse> |
listZones(LakeName parent)
public final DataplexServiceClient.ListZonesPagedResponse listZones(LakeName parent)
Lists zone resources in a lake.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
LakeName parent = LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]");
for (Zone element : dataplexServiceClient.listZones(parent).iterateAll()) {
// doThingsWith(element);
}
}
Name | Description |
parent | LakeName Required. The resource name of the parent lake:
|
Type | Description |
DataplexServiceClient.ListZonesPagedResponse |
listZones(ListZonesRequest request)
public final DataplexServiceClient.ListZonesPagedResponse listZones(ListZonesRequest request)
Lists zone resources in a lake.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ListZonesRequest request =
ListZonesRequest.newBuilder()
.setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.setFilter("filter-1274492040")
.setOrderBy("orderBy-1207110587")
.build();
for (Zone element : dataplexServiceClient.listZones(request).iterateAll()) {
// doThingsWith(element);
}
}
Name | Description |
request | ListZonesRequest The request object containing all of the parameters for the API call. |
Type | Description |
DataplexServiceClient.ListZonesPagedResponse |
listZones(String parent)
public final DataplexServiceClient.ListZonesPagedResponse listZones(String parent)
Lists zone resources in a lake.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
String parent = LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString();
for (Zone element : dataplexServiceClient.listZones(parent).iterateAll()) {
// doThingsWith(element);
}
}
Name | Description |
parent | String Required. The resource name of the parent lake:
|
Type | Description |
DataplexServiceClient.ListZonesPagedResponse |
listZonesCallable()
public final UnaryCallable<ListZonesRequest,ListZonesResponse> listZonesCallable()
Lists zone resources in a lake.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ListZonesRequest request =
ListZonesRequest.newBuilder()
.setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.setFilter("filter-1274492040")
.setOrderBy("orderBy-1207110587")
.build();
while (true) {
ListZonesResponse response = dataplexServiceClient.listZonesCallable().call(request);
for (Zone element : response.getZonesList()) {
// doThingsWith(element);
}
String nextPageToken = response.getNextPageToken();
if (!Strings.isNullOrEmpty(nextPageToken)) {
request = request.toBuilder().setPageToken(nextPageToken).build();
} else {
break;
}
}
}
Type | Description |
UnaryCallable<ListZonesRequest,ListZonesResponse> |
listZonesPagedCallable()
public final UnaryCallable<ListZonesRequest,DataplexServiceClient.ListZonesPagedResponse> listZonesPagedCallable()
Lists zone resources in a lake.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
ListZonesRequest request =
ListZonesRequest.newBuilder()
.setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.setFilter("filter-1274492040")
.setOrderBy("orderBy-1207110587")
.build();
ApiFuture<Zone> future = dataplexServiceClient.listZonesPagedCallable().futureCall(request);
// Do something.
for (Zone element : future.get().iterateAll()) {
// doThingsWith(element);
}
}
Type | Description |
UnaryCallable<ListZonesRequest,ListZonesPagedResponse> |
shutdown()
public void shutdown()
shutdownNow()
public void shutdownNow()
updateAssetAsync(Asset asset, FieldMask updateMask)
public final OperationFuture<Asset,OperationMetadata> updateAssetAsync(Asset asset, FieldMask updateMask)
Updates an asset resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
Asset asset = Asset.newBuilder().build();
FieldMask updateMask = FieldMask.newBuilder().build();
Asset response = dataplexServiceClient.updateAssetAsync(asset, updateMask).get();
}
Name | Description |
asset | Asset Required. Update description. Only fields specified in |
updateMask | FieldMask Required. Mask of fields to update. |
Type | Description |
OperationFuture<Asset,OperationMetadata> |
updateAssetAsync(UpdateAssetRequest request)
public final OperationFuture<Asset,OperationMetadata> updateAssetAsync(UpdateAssetRequest request)
Updates an asset resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
UpdateAssetRequest request =
UpdateAssetRequest.newBuilder()
.setUpdateMask(FieldMask.newBuilder().build())
.setAsset(Asset.newBuilder().build())
.setValidateOnly(true)
.build();
Asset response = dataplexServiceClient.updateAssetAsync(request).get();
}
Name | Description |
request | UpdateAssetRequest The request object containing all of the parameters for the API call. |
Type | Description |
OperationFuture<Asset,OperationMetadata> |
updateAssetCallable()
public final UnaryCallable<UpdateAssetRequest,Operation> updateAssetCallable()
Updates an asset resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
UpdateAssetRequest request =
UpdateAssetRequest.newBuilder()
.setUpdateMask(FieldMask.newBuilder().build())
.setAsset(Asset.newBuilder().build())
.setValidateOnly(true)
.build();
ApiFuture<Operation> future = dataplexServiceClient.updateAssetCallable().futureCall(request);
// Do something.
Operation response = future.get();
}
Type | Description |
UnaryCallable<UpdateAssetRequest,Operation> |
updateAssetOperationCallable()
public final OperationCallable<UpdateAssetRequest,Asset,OperationMetadata> updateAssetOperationCallable()
Updates an asset resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
UpdateAssetRequest request =
UpdateAssetRequest.newBuilder()
.setUpdateMask(FieldMask.newBuilder().build())
.setAsset(Asset.newBuilder().build())
.setValidateOnly(true)
.build();
OperationFuture<Asset, OperationMetadata> future =
dataplexServiceClient.updateAssetOperationCallable().futureCall(request);
// Do something.
Asset response = future.get();
}
Type | Description |
OperationCallable<UpdateAssetRequest,Asset,OperationMetadata> |
updateEnvironmentAsync(Environment environment, FieldMask updateMask)
public final OperationFuture<Environment,OperationMetadata> updateEnvironmentAsync(Environment environment, FieldMask updateMask)
Update the environment resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
Environment environment = Environment.newBuilder().build();
FieldMask updateMask = FieldMask.newBuilder().build();
Environment response =
dataplexServiceClient.updateEnvironmentAsync(environment, updateMask).get();
}
Name | Description |
environment | Environment Required. Update description. Only fields specified in |
updateMask | FieldMask Required. Mask of fields to update. |
Type | Description |
OperationFuture<Environment,OperationMetadata> |
updateEnvironmentAsync(UpdateEnvironmentRequest request)
public final OperationFuture<Environment,OperationMetadata> updateEnvironmentAsync(UpdateEnvironmentRequest request)
Update the environment resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
UpdateEnvironmentRequest request =
UpdateEnvironmentRequest.newBuilder()
.setUpdateMask(FieldMask.newBuilder().build())
.setEnvironment(Environment.newBuilder().build())
.setValidateOnly(true)
.build();
Environment response = dataplexServiceClient.updateEnvironmentAsync(request).get();
}
Name | Description |
request | UpdateEnvironmentRequest The request object containing all of the parameters for the API call. |
Type | Description |
OperationFuture<Environment,OperationMetadata> |
updateEnvironmentCallable()
public final UnaryCallable<UpdateEnvironmentRequest,Operation> updateEnvironmentCallable()
Update the environment resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
UpdateEnvironmentRequest request =
UpdateEnvironmentRequest.newBuilder()
.setUpdateMask(FieldMask.newBuilder().build())
.setEnvironment(Environment.newBuilder().build())
.setValidateOnly(true)
.build();
ApiFuture<Operation> future =
dataplexServiceClient.updateEnvironmentCallable().futureCall(request);
// Do something.
Operation response = future.get();
}
Type | Description |
UnaryCallable<UpdateEnvironmentRequest,Operation> |
updateEnvironmentOperationCallable()
public final OperationCallable<UpdateEnvironmentRequest,Environment,OperationMetadata> updateEnvironmentOperationCallable()
Update the environment resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
UpdateEnvironmentRequest request =
UpdateEnvironmentRequest.newBuilder()
.setUpdateMask(FieldMask.newBuilder().build())
.setEnvironment(Environment.newBuilder().build())
.setValidateOnly(true)
.build();
OperationFuture<Environment, OperationMetadata> future =
dataplexServiceClient.updateEnvironmentOperationCallable().futureCall(request);
// Do something.
Environment response = future.get();
}
Type | Description |
OperationCallable<UpdateEnvironmentRequest,Environment,OperationMetadata> |
updateLakeAsync(Lake lake, FieldMask updateMask)
public final OperationFuture<Lake,OperationMetadata> updateLakeAsync(Lake lake, FieldMask updateMask)
Updates a lake resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
Lake lake = Lake.newBuilder().build();
FieldMask updateMask = FieldMask.newBuilder().build();
Lake response = dataplexServiceClient.updateLakeAsync(lake, updateMask).get();
}
Name | Description |
lake | Lake Required. Update description. Only fields specified in |
updateMask | FieldMask Required. Mask of fields to update. |
Type | Description |
OperationFuture<Lake,OperationMetadata> |
updateLakeAsync(UpdateLakeRequest request)
public final OperationFuture<Lake,OperationMetadata> updateLakeAsync(UpdateLakeRequest request)
Updates a lake resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
UpdateLakeRequest request =
UpdateLakeRequest.newBuilder()
.setUpdateMask(FieldMask.newBuilder().build())
.setLake(Lake.newBuilder().build())
.setValidateOnly(true)
.build();
Lake response = dataplexServiceClient.updateLakeAsync(request).get();
}
Name | Description |
request | UpdateLakeRequest The request object containing all of the parameters for the API call. |
Type | Description |
OperationFuture<Lake,OperationMetadata> |
updateLakeCallable()
public final UnaryCallable<UpdateLakeRequest,Operation> updateLakeCallable()
Updates a lake resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
UpdateLakeRequest request =
UpdateLakeRequest.newBuilder()
.setUpdateMask(FieldMask.newBuilder().build())
.setLake(Lake.newBuilder().build())
.setValidateOnly(true)
.build();
ApiFuture<Operation> future = dataplexServiceClient.updateLakeCallable().futureCall(request);
// Do something.
Operation response = future.get();
}
Type | Description |
UnaryCallable<UpdateLakeRequest,Operation> |
updateLakeOperationCallable()
public final OperationCallable<UpdateLakeRequest,Lake,OperationMetadata> updateLakeOperationCallable()
Updates a lake resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
UpdateLakeRequest request =
UpdateLakeRequest.newBuilder()
.setUpdateMask(FieldMask.newBuilder().build())
.setLake(Lake.newBuilder().build())
.setValidateOnly(true)
.build();
OperationFuture<Lake, OperationMetadata> future =
dataplexServiceClient.updateLakeOperationCallable().futureCall(request);
// Do something.
Lake response = future.get();
}
Type | Description |
OperationCallable<UpdateLakeRequest,Lake,OperationMetadata> |
updateTaskAsync(Task task, FieldMask updateMask)
public final OperationFuture<Task,OperationMetadata> updateTaskAsync(Task task, FieldMask updateMask)
Update the task resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
Task task = Task.newBuilder().build();
FieldMask updateMask = FieldMask.newBuilder().build();
Task response = dataplexServiceClient.updateTaskAsync(task, updateMask).get();
}
Name | Description |
task | Task Required. Update description. Only fields specified in |
updateMask | FieldMask Required. Mask of fields to update. |
Type | Description |
OperationFuture<Task,OperationMetadata> |
updateTaskAsync(UpdateTaskRequest request)
public final OperationFuture<Task,OperationMetadata> updateTaskAsync(UpdateTaskRequest request)
Update the task resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
UpdateTaskRequest request =
UpdateTaskRequest.newBuilder()
.setUpdateMask(FieldMask.newBuilder().build())
.setTask(Task.newBuilder().build())
.setValidateOnly(true)
.build();
Task response = dataplexServiceClient.updateTaskAsync(request).get();
}
Name | Description |
request | UpdateTaskRequest The request object containing all of the parameters for the API call. |
Type | Description |
OperationFuture<Task,OperationMetadata> |
updateTaskCallable()
public final UnaryCallable<UpdateTaskRequest,Operation> updateTaskCallable()
Update the task resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
UpdateTaskRequest request =
UpdateTaskRequest.newBuilder()
.setUpdateMask(FieldMask.newBuilder().build())
.setTask(Task.newBuilder().build())
.setValidateOnly(true)
.build();
ApiFuture<Operation> future = dataplexServiceClient.updateTaskCallable().futureCall(request);
// Do something.
Operation response = future.get();
}
Type | Description |
UnaryCallable<UpdateTaskRequest,Operation> |
updateTaskOperationCallable()
public final OperationCallable<UpdateTaskRequest,Task,OperationMetadata> updateTaskOperationCallable()
Update the task resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
UpdateTaskRequest request =
UpdateTaskRequest.newBuilder()
.setUpdateMask(FieldMask.newBuilder().build())
.setTask(Task.newBuilder().build())
.setValidateOnly(true)
.build();
OperationFuture<Task, OperationMetadata> future =
dataplexServiceClient.updateTaskOperationCallable().futureCall(request);
// Do something.
Task response = future.get();
}
Type | Description |
OperationCallable<UpdateTaskRequest,Task,OperationMetadata> |
updateZoneAsync(UpdateZoneRequest request)
public final OperationFuture<Zone,OperationMetadata> updateZoneAsync(UpdateZoneRequest request)
Updates a zone resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
UpdateZoneRequest request =
UpdateZoneRequest.newBuilder()
.setUpdateMask(FieldMask.newBuilder().build())
.setZone(Zone.newBuilder().build())
.setValidateOnly(true)
.build();
Zone response = dataplexServiceClient.updateZoneAsync(request).get();
}
Name | Description |
request | UpdateZoneRequest The request object containing all of the parameters for the API call. |
Type | Description |
OperationFuture<Zone,OperationMetadata> |
updateZoneAsync(Zone zone, FieldMask updateMask)
public final OperationFuture<Zone,OperationMetadata> updateZoneAsync(Zone zone, FieldMask updateMask)
Updates a zone resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
Zone zone = Zone.newBuilder().build();
FieldMask updateMask = FieldMask.newBuilder().build();
Zone response = dataplexServiceClient.updateZoneAsync(zone, updateMask).get();
}
Name | Description |
zone | Zone Required. Update description. Only fields specified in |
updateMask | FieldMask Required. Mask of fields to update. |
Type | Description |
OperationFuture<Zone,OperationMetadata> |
updateZoneCallable()
public final UnaryCallable<UpdateZoneRequest,Operation> updateZoneCallable()
Updates a zone resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
UpdateZoneRequest request =
UpdateZoneRequest.newBuilder()
.setUpdateMask(FieldMask.newBuilder().build())
.setZone(Zone.newBuilder().build())
.setValidateOnly(true)
.build();
ApiFuture<Operation> future = dataplexServiceClient.updateZoneCallable().futureCall(request);
// Do something.
Operation response = future.get();
}
Type | Description |
UnaryCallable<UpdateZoneRequest,Operation> |
updateZoneOperationCallable()
public final OperationCallable<UpdateZoneRequest,Zone,OperationMetadata> updateZoneOperationCallable()
Updates a zone resource.
Sample code:
// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
UpdateZoneRequest request =
UpdateZoneRequest.newBuilder()
.setUpdateMask(FieldMask.newBuilder().build())
.setZone(Zone.newBuilder().build())
.setValidateOnly(true)
.build();
OperationFuture<Zone, OperationMetadata> future =
dataplexServiceClient.updateZoneOperationCallable().futureCall(request);
// Do something.
Zone response = future.get();
}
Type | Description |
OperationCallable<UpdateZoneRequest,Zone,OperationMetadata> |