Class DataFusionClient (1.44.0)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
GetInstanceRequestrequest=
GetInstanceRequest.newBuilder()
.setName(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.build();
Instanceresponse=dataFusionClient.getInstance(request);
}

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
DataFusionSettingsdataFusionSettings=
DataFusionSettings.newBuilder()
.setCredentialsProvider(FixedCredentialsProvider.create(myCredentials))
.build();
DataFusionClientdataFusionClient=DataFusionClient.create(dataFusionSettings);

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
DataFusionSettingsdataFusionSettings=
DataFusionSettings.newBuilder().setEndpoint(myEndpoint).build();
DataFusionClientdataFusionClient=DataFusionClient.create(dataFusionSettings);

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
DataFusionSettingsdataFusionSettings=DataFusionSettings.newHttpJsonBuilder().build();
DataFusionClientdataFusionClient=DataFusionClient.create(dataFusionSettings);

publicstaticfinalDataFusionClientcreate()

publicstaticfinalDataFusionClientcreate(DataFusionSettingssettings)

publicstaticfinalDataFusionClientcreate(DataFusionStubstub)

protectedDataFusionClient(DataFusionSettingssettings)

protectedDataFusionClient(DataFusionStubstub)

publicfinalAddDnsPeeringResponseaddDnsPeering(AddDnsPeeringRequestrequest)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
AddDnsPeeringRequestrequest=
AddDnsPeeringRequest.newBuilder()
.setParent(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.setDnsPeering(DnsPeering.newBuilder().build())
.build();
AddDnsPeeringResponseresponse=dataFusionClient.addDnsPeering(request);
}

publicfinalAddDnsPeeringResponseaddDnsPeering(InstanceNameparent)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
InstanceNameparent=InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]");
AddDnsPeeringResponseresponse=dataFusionClient.addDnsPeering(parent);
}

publicfinalAddDnsPeeringResponseaddDnsPeering(Stringparent)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
Stringparent=InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString();
AddDnsPeeringResponseresponse=dataFusionClient.addDnsPeering(parent);
}

publicfinalUnaryCallable<AddDnsPeeringRequest,AddDnsPeeringResponse>addDnsPeeringCallable()

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
AddDnsPeeringRequestrequest=
AddDnsPeeringRequest.newBuilder()
.setParent(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.setDnsPeering(DnsPeering.newBuilder().build())
.build();
ApiFuture<AddDnsPeeringResponse>future=
dataFusionClient.addDnsPeeringCallable().futureCall(request);
// Do something.
AddDnsPeeringResponseresponse=future.get();
}

publicbooleanawaitTermination(longduration,TimeUnitunit)

publicfinalvoidclose()

publicfinalOperationFuture<Instance,OperationMetadata>createInstanceAsync(CreateInstanceRequestrequest)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
CreateInstanceRequestrequest=
CreateInstanceRequest.newBuilder()
.setParent(LocationName.of("[PROJECT]","[LOCATION]").toString())
.setInstanceId("instanceId902024336")
.setInstance(Instance.newBuilder().build())
.build();
Instanceresponse=dataFusionClient.createInstanceAsync(request).get();
}

publicfinalOperationFuture<Instance,OperationMetadata>createInstanceAsync(LocationNameparent,Instanceinstance,StringinstanceId)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
LocationNameparent=LocationName.of("[PROJECT]","[LOCATION]");
Instanceinstance=Instance.newBuilder().build();
StringinstanceId="instanceId902024336";
Instanceresponse=dataFusionClient.createInstanceAsync(parent,instance,instanceId).get();
}

publicfinalOperationFuture<Instance,OperationMetadata>createInstanceAsync(Stringparent,Instanceinstance,StringinstanceId)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
Stringparent=LocationName.of("[PROJECT]","[LOCATION]").toString();
Instanceinstance=Instance.newBuilder().build();
StringinstanceId="instanceId902024336";
Instanceresponse=dataFusionClient.createInstanceAsync(parent,instance,instanceId).get();
}

publicfinalUnaryCallable<CreateInstanceRequest,Operation>createInstanceCallable()

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
CreateInstanceRequestrequest=
CreateInstanceRequest.newBuilder()
.setParent(LocationName.of("[PROJECT]","[LOCATION]").toString())
.setInstanceId("instanceId902024336")
.setInstance(Instance.newBuilder().build())
.build();
ApiFuture<Operation>future=dataFusionClient.createInstanceCallable().futureCall(request);
// Do something.
Operationresponse=future.get();
}

publicfinalOperationCallable<CreateInstanceRequest,Instance,OperationMetadata>createInstanceOperationCallable()

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
CreateInstanceRequestrequest=
CreateInstanceRequest.newBuilder()
.setParent(LocationName.of("[PROJECT]","[LOCATION]").toString())
.setInstanceId("instanceId902024336")
.setInstance(Instance.newBuilder().build())
.build();
OperationFuture<Instance,OperationMetadata>future=
dataFusionClient.createInstanceOperationCallable().futureCall(request);
// Do something.
Instanceresponse=future.get();
}

publicfinalOperationFuture<Empty,OperationMetadata>deleteInstanceAsync(DeleteInstanceRequestrequest)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
DeleteInstanceRequestrequest=
DeleteInstanceRequest.newBuilder()
.setName(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.build();
dataFusionClient.deleteInstanceAsync(request).get();
}

publicfinalOperationFuture<Empty,OperationMetadata>deleteInstanceAsync(InstanceNamename)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
InstanceNamename=InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]");
dataFusionClient.deleteInstanceAsync(name).get();
}

publicfinalOperationFuture<Empty,OperationMetadata>deleteInstanceAsync(Stringname)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
Stringname=InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString();
dataFusionClient.deleteInstanceAsync(name).get();
}

publicfinalUnaryCallable<DeleteInstanceRequest,Operation>deleteInstanceCallable()

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
DeleteInstanceRequestrequest=
DeleteInstanceRequest.newBuilder()
.setName(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.build();
ApiFuture<Operation>future=dataFusionClient.deleteInstanceCallable().futureCall(request);
// Do something.
future.get();
}

publicfinalOperationCallable<DeleteInstanceRequest,Empty,OperationMetadata>deleteInstanceOperationCallable()

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
DeleteInstanceRequestrequest=
DeleteInstanceRequest.newBuilder()
.setName(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.build();
OperationFuture<Empty,OperationMetadata>future=
dataFusionClient.deleteInstanceOperationCallable().futureCall(request);
// Do something.
future.get();
}

publicfinalOperationsClientgetHttpJsonOperationsClient()

publicfinalInstancegetInstance(GetInstanceRequestrequest)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
GetInstanceRequestrequest=
GetInstanceRequest.newBuilder()
.setName(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.build();
Instanceresponse=dataFusionClient.getInstance(request);
}

publicfinalUnaryCallable<GetInstanceRequest,Instance>getInstanceCallable()

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
GetInstanceRequestrequest=
GetInstanceRequest.newBuilder()
.setName(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.build();
ApiFuture<Instance>future=dataFusionClient.getInstanceCallable().futureCall(request);
// Do something.
Instanceresponse=future.get();
}

publicfinalOperationsClientgetOperationsClient()

publicfinalDataFusionSettingsgetSettings()

publicDataFusionStubgetStub()

publicbooleanisShutdown()

publicbooleanisTerminated()

publicfinalDataFusionClient.ListAvailableVersionsPagedResponselistAvailableVersions(ListAvailableVersionsRequestrequest)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
ListAvailableVersionsRequestrequest=
ListAvailableVersionsRequest.newBuilder()
.setParent(LocationName.of("[PROJECT]","[LOCATION]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.setLatestPatchOnly(true)
.build();
for(Versionelement:dataFusionClient.listAvailableVersions(request).iterateAll()){
// doThingsWith(element);
}
}

publicfinalDataFusionClient.ListAvailableVersionsPagedResponselistAvailableVersions(LocationNameparent)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
LocationNameparent=LocationName.of("[PROJECT]","[LOCATION]");
for(Versionelement:dataFusionClient.listAvailableVersions(parent).iterateAll()){
// doThingsWith(element);
}
}

publicfinalDataFusionClient.ListAvailableVersionsPagedResponselistAvailableVersions(Stringparent)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
Stringparent=LocationName.of("[PROJECT]","[LOCATION]").toString();
for(Versionelement:dataFusionClient.listAvailableVersions(parent).iterateAll()){
// doThingsWith(element);
}
}

publicfinalUnaryCallable<ListAvailableVersionsRequest,ListAvailableVersionsResponse>listAvailableVersionsCallable()

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
ListAvailableVersionsRequestrequest=
ListAvailableVersionsRequest.newBuilder()
.setParent(LocationName.of("[PROJECT]","[LOCATION]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.setLatestPatchOnly(true)
.build();
while(true){
ListAvailableVersionsResponseresponse=
dataFusionClient.listAvailableVersionsCallable().call(request);
for(Versionelement:response.getAvailableVersionsList()){
// doThingsWith(element);
}
StringnextPageToken=response.getNextPageToken();
if(!Strings.isNullOrEmpty(nextPageToken)){
request=request.toBuilder().setPageToken(nextPageToken).build();
}else{
break;
}
}
}

publicfinalUnaryCallable<ListAvailableVersionsRequest,DataFusionClient.ListAvailableVersionsPagedResponse>listAvailableVersionsPagedCallable()

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
ListAvailableVersionsRequestrequest=
ListAvailableVersionsRequest.newBuilder()
.setParent(LocationName.of("[PROJECT]","[LOCATION]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.setLatestPatchOnly(true)
.build();
ApiFuture<Version>future=
dataFusionClient.listAvailableVersionsPagedCallable().futureCall(request);
// Do something.
for(Versionelement:future.get().iterateAll()){
// doThingsWith(element);
}
}

publicfinalDataFusionClient.ListDnsPeeringsPagedResponselistDnsPeerings(InstanceNameparent)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
InstanceNameparent=InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]");
for(DnsPeeringelement:dataFusionClient.listDnsPeerings(parent).iterateAll()){
// doThingsWith(element);
}
}

publicfinalDataFusionClient.ListDnsPeeringsPagedResponselistDnsPeerings(ListDnsPeeringsRequestrequest)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
ListDnsPeeringsRequestrequest=
ListDnsPeeringsRequest.newBuilder()
.setParent(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.build();
for(DnsPeeringelement:dataFusionClient.listDnsPeerings(request).iterateAll()){
// doThingsWith(element);
}
}

publicfinalDataFusionClient.ListDnsPeeringsPagedResponselistDnsPeerings(Stringparent)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
Stringparent=InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString();
for(DnsPeeringelement:dataFusionClient.listDnsPeerings(parent).iterateAll()){
// doThingsWith(element);
}
}

publicfinalUnaryCallable<ListDnsPeeringsRequest,ListDnsPeeringsResponse>listDnsPeeringsCallable()

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
ListDnsPeeringsRequestrequest=
ListDnsPeeringsRequest.newBuilder()
.setParent(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.build();
while(true){
ListDnsPeeringsResponseresponse=dataFusionClient.listDnsPeeringsCallable().call(request);
for(DnsPeeringelement:response.getDnsPeeringsList()){
// doThingsWith(element);
}
StringnextPageToken=response.getNextPageToken();
if(!Strings.isNullOrEmpty(nextPageToken)){
request=request.toBuilder().setPageToken(nextPageToken).build();
}else{
break;
}
}
}

publicfinalUnaryCallable<ListDnsPeeringsRequest,DataFusionClient.ListDnsPeeringsPagedResponse>listDnsPeeringsPagedCallable()

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
ListDnsPeeringsRequestrequest=
ListDnsPeeringsRequest.newBuilder()
.setParent(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.build();
ApiFuture<DnsPeering>future=
dataFusionClient.listDnsPeeringsPagedCallable().futureCall(request);
// Do something.
for(DnsPeeringelement:future.get().iterateAll()){
// doThingsWith(element);
}
}

publicfinalDataFusionClient.ListInstancesPagedResponselistInstances(ListInstancesRequestrequest)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
ListInstancesRequestrequest=
ListInstancesRequest.newBuilder()
.setParent(LocationName.of("[PROJECT]","[LOCATION]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.setFilter("filter-1274492040")
.setOrderBy("orderBy-1207110587")
.build();
for(Instanceelement:dataFusionClient.listInstances(request).iterateAll()){
// doThingsWith(element);
}
}

publicfinalUnaryCallable<ListInstancesRequest,ListInstancesResponse>listInstancesCallable()

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
ListInstancesRequestrequest=
ListInstancesRequest.newBuilder()
.setParent(LocationName.of("[PROJECT]","[LOCATION]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.setFilter("filter-1274492040")
.setOrderBy("orderBy-1207110587")
.build();
while(true){
ListInstancesResponseresponse=dataFusionClient.listInstancesCallable().call(request);
for(Instanceelement:response.getInstancesList()){
// doThingsWith(element);
}
StringnextPageToken=response.getNextPageToken();
if(!Strings.isNullOrEmpty(nextPageToken)){
request=request.toBuilder().setPageToken(nextPageToken).build();
}else{
break;
}
}
}

publicfinalUnaryCallable<ListInstancesRequest,DataFusionClient.ListInstancesPagedResponse>listInstancesPagedCallable()

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
ListInstancesRequestrequest=
ListInstancesRequest.newBuilder()
.setParent(LocationName.of("[PROJECT]","[LOCATION]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.setFilter("filter-1274492040")
.setOrderBy("orderBy-1207110587")
.build();
ApiFuture<Instance>future=
dataFusionClient.listInstancesPagedCallable().futureCall(request);
// Do something.
for(Instanceelement:future.get().iterateAll()){
// doThingsWith(element);
}
}

publicfinalDataFusionClient.ListNamespacesPagedResponselistNamespaces(InstanceNameparent)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
InstanceNameparent=InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]");
for(Namespaceelement:dataFusionClient.listNamespaces(parent).iterateAll()){
// doThingsWith(element);
}
}

publicfinalDataFusionClient.ListNamespacesPagedResponselistNamespaces(ListNamespacesRequestrequest)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
ListNamespacesRequestrequest=
ListNamespacesRequest.newBuilder()
.setParent(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.setView(NamespaceView.forNumber(0))
.build();
for(Namespaceelement:dataFusionClient.listNamespaces(request).iterateAll()){
// doThingsWith(element);
}
}

publicfinalDataFusionClient.ListNamespacesPagedResponselistNamespaces(Stringparent)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
Stringparent=InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString();
for(Namespaceelement:dataFusionClient.listNamespaces(parent).iterateAll()){
// doThingsWith(element);
}
}

publicfinalUnaryCallable<ListNamespacesRequest,ListNamespacesResponse>listNamespacesCallable()

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
ListNamespacesRequestrequest=
ListNamespacesRequest.newBuilder()
.setParent(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.setView(NamespaceView.forNumber(0))
.build();
while(true){
ListNamespacesResponseresponse=dataFusionClient.listNamespacesCallable().call(request);
for(Namespaceelement:response.getNamespacesList()){
// doThingsWith(element);
}
StringnextPageToken=response.getNextPageToken();
if(!Strings.isNullOrEmpty(nextPageToken)){
request=request.toBuilder().setPageToken(nextPageToken).build();
}else{
break;
}
}
}

publicfinalUnaryCallable<ListNamespacesRequest,DataFusionClient.ListNamespacesPagedResponse>listNamespacesPagedCallable()

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
ListNamespacesRequestrequest=
ListNamespacesRequest.newBuilder()
.setParent(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.setView(NamespaceView.forNumber(0))
.build();
ApiFuture<Namespace>future=
dataFusionClient.listNamespacesPagedCallable().futureCall(request);
// Do something.
for(Namespaceelement:future.get().iterateAll()){
// doThingsWith(element);
}
}

publicfinalRemoveDnsPeeringResponseremoveDnsPeering(InstanceNameparent)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
InstanceNameparent=InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]");
RemoveDnsPeeringResponseresponse=dataFusionClient.removeDnsPeering(parent);
}

publicfinalRemoveDnsPeeringResponseremoveDnsPeering(RemoveDnsPeeringRequestrequest)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
RemoveDnsPeeringRequestrequest=
RemoveDnsPeeringRequest.newBuilder()
.setParent(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.setZone("zone3744684")
.build();
RemoveDnsPeeringResponseresponse=dataFusionClient.removeDnsPeering(request);
}

publicfinalRemoveDnsPeeringResponseremoveDnsPeering(Stringparent)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
Stringparent=InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString();
RemoveDnsPeeringResponseresponse=dataFusionClient.removeDnsPeering(parent);
}

publicfinalUnaryCallable<RemoveDnsPeeringRequest,RemoveDnsPeeringResponse>removeDnsPeeringCallable()

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
RemoveDnsPeeringRequestrequest=
RemoveDnsPeeringRequest.newBuilder()
.setParent(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.setZone("zone3744684")
.build();
ApiFuture<RemoveDnsPeeringResponse>future=
dataFusionClient.removeDnsPeeringCallable().futureCall(request);
// Do something.
RemoveDnsPeeringResponseresponse=future.get();
}

publicfinalRemoveIamPolicyResponseremoveIamPolicy(RemoveIamPolicyRequestrequest)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
RemoveIamPolicyRequestrequest=
RemoveIamPolicyRequest.newBuilder().setResource("resource-341064690").build();
RemoveIamPolicyResponseresponse=dataFusionClient.removeIamPolicy(request);
}

publicfinalUnaryCallable<RemoveIamPolicyRequest,RemoveIamPolicyResponse>removeIamPolicyCallable()

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
RemoveIamPolicyRequestrequest=
RemoveIamPolicyRequest.newBuilder().setResource("resource-341064690").build();
ApiFuture<RemoveIamPolicyResponse>future=
dataFusionClient.removeIamPolicyCallable().futureCall(request);
// Do something.
RemoveIamPolicyResponseresponse=future.get();
}

publicfinalOperationFuture<Instance,OperationMetadata>restartInstanceAsync(RestartInstanceRequestrequest)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
RestartInstanceRequestrequest=
RestartInstanceRequest.newBuilder()
.setName(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.build();
Instanceresponse=dataFusionClient.restartInstanceAsync(request).get();
}

publicfinalUnaryCallable<RestartInstanceRequest,Operation>restartInstanceCallable()

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
RestartInstanceRequestrequest=
RestartInstanceRequest.newBuilder()
.setName(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.build();
ApiFuture<Operation>future=dataFusionClient.restartInstanceCallable().futureCall(request);
// Do something.
Operationresponse=future.get();
}

publicfinalOperationCallable<RestartInstanceRequest,Instance,OperationMetadata>restartInstanceOperationCallable()

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
RestartInstanceRequestrequest=
RestartInstanceRequest.newBuilder()
.setName(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.build();
OperationFuture<Instance,OperationMetadata>future=
dataFusionClient.restartInstanceOperationCallable().futureCall(request);
// Do something.
Instanceresponse=future.get();
}

publicvoidshutdown()

publicvoidshutdownNow()

publicfinalOperationFuture<Instance,OperationMetadata>updateInstanceAsync(Instanceinstance,FieldMaskupdateMask)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
Instanceinstance=Instance.newBuilder().build();
FieldMaskupdateMask=FieldMask.newBuilder().build();
Instanceresponse=dataFusionClient.updateInstanceAsync(instance,updateMask).get();
}

publicfinalOperationFuture<Instance,OperationMetadata>updateInstanceAsync(UpdateInstanceRequestrequest)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
UpdateInstanceRequestrequest=
UpdateInstanceRequest.newBuilder()
.setInstance(Instance.newBuilder().build())
.setUpdateMask(FieldMask.newBuilder().build())
.build();
Instanceresponse=dataFusionClient.updateInstanceAsync(request).get();
}

publicfinalUnaryCallable<UpdateInstanceRequest,Operation>updateInstanceCallable()

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
UpdateInstanceRequestrequest=
UpdateInstanceRequest.newBuilder()
.setInstance(Instance.newBuilder().build())
.setUpdateMask(FieldMask.newBuilder().build())
.build();
ApiFuture<Operation>future=dataFusionClient.updateInstanceCallable().futureCall(request);
// Do something.
Operationresponse=future.get();
}

publicfinalOperationCallable<UpdateInstanceRequest,Instance,OperationMetadata>updateInstanceOperationCallable()

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
UpdateInstanceRequestrequest=
UpdateInstanceRequest.newBuilder()
.setInstance(Instance.newBuilder().build())
.setUpdateMask(FieldMask.newBuilder().build())
.build();
OperationFuture<Instance,OperationMetadata>future=
dataFusionClient.updateInstanceOperationCallable().futureCall(request);
// Do something.
Instanceresponse=future.get();
}

publicfinalOperationFuture<Instance,OperationMetadata>upgradeInstanceAsync(UpgradeInstanceRequestrequest)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
UpgradeInstanceRequestrequest=
UpgradeInstanceRequest.newBuilder()
.setName(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.build();
Instanceresponse=dataFusionClient.upgradeInstanceAsync(request).get();
}

publicfinalUnaryCallable<UpgradeInstanceRequest,Operation>upgradeInstanceCallable()

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
UpgradeInstanceRequestrequest=
UpgradeInstanceRequest.newBuilder()
.setName(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.build();
ApiFuture<Operation>future=dataFusionClient.upgradeInstanceCallable().futureCall(request);
// Do something.
Operationresponse=future.get();
}

publicfinalOperationCallable<UpgradeInstanceRequest,Instance,OperationMetadata>upgradeInstanceOperationCallable()

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(DataFusionClientdataFusionClient=DataFusionClient.create()){
UpgradeInstanceRequestrequest=
UpgradeInstanceRequest.newBuilder()
.setName(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.build();
OperationFuture<Instance,OperationMetadata>future=
dataFusionClient.upgradeInstanceOperationCallable().futureCall(request);
// Do something.
Instanceresponse=future.get();
}