Class AnalyticsHubServiceClient
- java.lang.Object
-
- com.google.cloud.bigquery.dataexchange.v1beta1.AnalyticsHubServiceClient
-
- All Implemented Interfaces:
com.google.api.gax.core.BackgroundResource
,AutoCloseable
@BetaApi @Generated("by gapic-generator-java") public class AnalyticsHubServiceClient extends Object implements com.google.api.gax.core.BackgroundResource
Service Description: The `AnalyticsHubService` API facilitates data sharing within and across organizations. It allows data providers to publish listings that reference shared datasets. With Analytics Hub, users can discover and search for listings that they have access to. Subscribers can view and subscribe to listings. When you subscribe to a listing, Analytics Hub creates a linked dataset in your project.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 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { DataExchangeName name = DataExchangeName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]"); DataExchange response = analyticsHubServiceClient.getDataExchange(name); }
Note: close() needs to be called on the AnalyticsHubServiceClient 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 AnalyticsHubServiceSettings to create(). For example:
To customize credentials:
// 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 AnalyticsHubServiceSettings analyticsHubServiceSettings = AnalyticsHubServiceSettings.newBuilder() .setCredentialsProvider(FixedCredentialsProvider.create(myCredentials)) .build(); AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create(analyticsHubServiceSettings);
To customize the endpoint:
// 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 AnalyticsHubServiceSettings analyticsHubServiceSettings = AnalyticsHubServiceSettings.newBuilder().setEndpoint(myEndpoint).build(); AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create(analyticsHubServiceSettings);
To use REST (HTTP1.1/JSON) transport (instead of gRPC) for sending and receiving requests over the wire:
// 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 AnalyticsHubServiceSettings analyticsHubServiceSettings = AnalyticsHubServiceSettings.newHttpJsonBuilder().build(); AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create(analyticsHubServiceSettings);
Please refer to the GitHub repository's samples for more quickstart code snippets.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
AnalyticsHubServiceClient.ListDataExchangesFixedSizeCollection
static class
AnalyticsHubServiceClient.ListDataExchangesPage
static class
AnalyticsHubServiceClient.ListDataExchangesPagedResponse
static class
AnalyticsHubServiceClient.ListListingsFixedSizeCollection
static class
AnalyticsHubServiceClient.ListListingsPage
static class
AnalyticsHubServiceClient.ListListingsPagedResponse
static class
AnalyticsHubServiceClient.ListLocationsFixedSizeCollection
static class
AnalyticsHubServiceClient.ListLocationsPage
static class
AnalyticsHubServiceClient.ListLocationsPagedResponse
static class
AnalyticsHubServiceClient.ListOrgDataExchangesFixedSizeCollection
static class
AnalyticsHubServiceClient.ListOrgDataExchangesPage
static class
AnalyticsHubServiceClient.ListOrgDataExchangesPagedResponse
-
Constructor Summary
Constructors Modifier Constructor Description protected
AnalyticsHubServiceClient(AnalyticsHubServiceSettings settings)
Constructs an instance of AnalyticsHubServiceClient, using the given settings.protected
AnalyticsHubServiceClient(AnalyticsHubServiceStub stub)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
awaitTermination(long duration, TimeUnit unit)
void
close()
static AnalyticsHubServiceClient
create()
Constructs an instance of AnalyticsHubServiceClient with default settings.static AnalyticsHubServiceClient
create(AnalyticsHubServiceSettings settings)
Constructs an instance of AnalyticsHubServiceClient, using the given settings.static AnalyticsHubServiceClient
create(AnalyticsHubServiceStub stub)
Constructs an instance of AnalyticsHubServiceClient, using the given stub for making calls.DataExchange
createDataExchange(CreateDataExchangeRequest request)
Creates a new data exchange.DataExchange
createDataExchange(LocationName parent, DataExchange dataExchange)
Creates a new data exchange.DataExchange
createDataExchange(String parent, DataExchange dataExchange)
Creates a new data exchange.com.google.api.gax.rpc.UnaryCallable<CreateDataExchangeRequest,DataExchange>
createDataExchangeCallable()
Creates a new data exchange.Listing
createListing(CreateListingRequest request)
Creates a new listing.Listing
createListing(DataExchangeName parent, Listing listing)
Creates a new listing.Listing
createListing(String parent, Listing listing)
Creates a new listing.com.google.api.gax.rpc.UnaryCallable<CreateListingRequest,Listing>
createListingCallable()
Creates a new listing.void
deleteDataExchange(DataExchangeName name)
Deletes an existing data exchange.void
deleteDataExchange(DeleteDataExchangeRequest request)
Deletes an existing data exchange.void
deleteDataExchange(String name)
Deletes an existing data exchange.com.google.api.gax.rpc.UnaryCallable<DeleteDataExchangeRequest,com.google.protobuf.Empty>
deleteDataExchangeCallable()
Deletes an existing data exchange.void
deleteListing(DeleteListingRequest request)
Deletes a listing.void
deleteListing(ListingName name)
Deletes a listing.void
deleteListing(String name)
Deletes a listing.com.google.api.gax.rpc.UnaryCallable<DeleteListingRequest,com.google.protobuf.Empty>
deleteListingCallable()
Deletes a listing.DataExchange
getDataExchange(DataExchangeName name)
Gets the details of a data exchange.DataExchange
getDataExchange(GetDataExchangeRequest request)
Gets the details of a data exchange.DataExchange
getDataExchange(String name)
Gets the details of a data exchange.com.google.api.gax.rpc.UnaryCallable<GetDataExchangeRequest,DataExchange>
getDataExchangeCallable()
Gets the details of a data exchange.com.google.iam.v1.Policy
getIamPolicy(com.google.iam.v1.GetIamPolicyRequest request)
Gets the IAM policy.com.google.api.gax.rpc.UnaryCallable<com.google.iam.v1.GetIamPolicyRequest,com.google.iam.v1.Policy>
getIamPolicyCallable()
Gets the IAM policy.Listing
getListing(GetListingRequest request)
Gets the details of a listing.Listing
getListing(ListingName name)
Gets the details of a listing.Listing
getListing(String name)
Gets the details of a listing.com.google.api.gax.rpc.UnaryCallable<GetListingRequest,Listing>
getListingCallable()
Gets the details of a listing.com.google.cloud.location.Location
getLocation(com.google.cloud.location.GetLocationRequest request)
Gets information about a location.com.google.api.gax.rpc.UnaryCallable<com.google.cloud.location.GetLocationRequest,com.google.cloud.location.Location>
getLocationCallable()
Gets information about a location.AnalyticsHubServiceSettings
getSettings()
AnalyticsHubServiceStub
getStub()
boolean
isShutdown()
boolean
isTerminated()
AnalyticsHubServiceClient.ListDataExchangesPagedResponse
listDataExchanges(ListDataExchangesRequest request)
Lists all data exchanges in a given project and location.AnalyticsHubServiceClient.ListDataExchangesPagedResponse
listDataExchanges(LocationName parent)
Lists all data exchanges in a given project and location.AnalyticsHubServiceClient.ListDataExchangesPagedResponse
listDataExchanges(String parent)
Lists all data exchanges in a given project and location.com.google.api.gax.rpc.UnaryCallable<ListDataExchangesRequest,ListDataExchangesResponse>
listDataExchangesCallable()
Lists all data exchanges in a given project and location.com.google.api.gax.rpc.UnaryCallable<ListDataExchangesRequest,AnalyticsHubServiceClient.ListDataExchangesPagedResponse>
listDataExchangesPagedCallable()
Lists all data exchanges in a given project and location.AnalyticsHubServiceClient.ListListingsPagedResponse
listListings(DataExchangeName parent)
Lists all listings in a given project and location.AnalyticsHubServiceClient.ListListingsPagedResponse
listListings(ListListingsRequest request)
Lists all listings in a given project and location.AnalyticsHubServiceClient.ListListingsPagedResponse
listListings(String parent)
Lists all listings in a given project and location.com.google.api.gax.rpc.UnaryCallable<ListListingsRequest,ListListingsResponse>
listListingsCallable()
Lists all listings in a given project and location.com.google.api.gax.rpc.UnaryCallable<ListListingsRequest,AnalyticsHubServiceClient.ListListingsPagedResponse>
listListingsPagedCallable()
Lists all listings in a given project and location.AnalyticsHubServiceClient.ListLocationsPagedResponse
listLocations(com.google.cloud.location.ListLocationsRequest request)
Lists information about the supported locations for this service.com.google.api.gax.rpc.UnaryCallable<com.google.cloud.location.ListLocationsRequest,com.google.cloud.location.ListLocationsResponse>
listLocationsCallable()
Lists information about the supported locations for this service.com.google.api.gax.rpc.UnaryCallable<com.google.cloud.location.ListLocationsRequest,AnalyticsHubServiceClient.ListLocationsPagedResponse>
listLocationsPagedCallable()
Lists information about the supported locations for this service.AnalyticsHubServiceClient.ListOrgDataExchangesPagedResponse
listOrgDataExchanges(ListOrgDataExchangesRequest request)
Lists all data exchanges from projects in a given organization and location.AnalyticsHubServiceClient.ListOrgDataExchangesPagedResponse
listOrgDataExchanges(String organization)
Lists all data exchanges from projects in a given organization and location.com.google.api.gax.rpc.UnaryCallable<ListOrgDataExchangesRequest,ListOrgDataExchangesResponse>
listOrgDataExchangesCallable()
Lists all data exchanges from projects in a given organization and location.com.google.api.gax.rpc.UnaryCallable<ListOrgDataExchangesRequest,AnalyticsHubServiceClient.ListOrgDataExchangesPagedResponse>
listOrgDataExchangesPagedCallable()
Lists all data exchanges from projects in a given organization and location.com.google.iam.v1.Policy
setIamPolicy(com.google.iam.v1.SetIamPolicyRequest request)
Sets the IAM policy.com.google.api.gax.rpc.UnaryCallable<com.google.iam.v1.SetIamPolicyRequest,com.google.iam.v1.Policy>
setIamPolicyCallable()
Sets the IAM policy.void
shutdown()
void
shutdownNow()
SubscribeListingResponse
subscribeListing(ListingName name)
Subscribes to a listing.SubscribeListingResponse
subscribeListing(SubscribeListingRequest request)
Subscribes to a listing.SubscribeListingResponse
subscribeListing(String name)
Subscribes to a listing.com.google.api.gax.rpc.UnaryCallable<SubscribeListingRequest,SubscribeListingResponse>
subscribeListingCallable()
Subscribes to a listing.com.google.iam.v1.TestIamPermissionsResponse
testIamPermissions(com.google.iam.v1.TestIamPermissionsRequest request)
Returns the permissions that a caller has.com.google.api.gax.rpc.UnaryCallable<com.google.iam.v1.TestIamPermissionsRequest,com.google.iam.v1.TestIamPermissionsResponse>
testIamPermissionsCallable()
Returns the permissions that a caller has.DataExchange
updateDataExchange(DataExchange dataExchange, com.google.protobuf.FieldMask updateMask)
Updates an existing data exchange.DataExchange
updateDataExchange(UpdateDataExchangeRequest request)
Updates an existing data exchange.com.google.api.gax.rpc.UnaryCallable<UpdateDataExchangeRequest,DataExchange>
updateDataExchangeCallable()
Updates an existing data exchange.Listing
updateListing(Listing listing, com.google.protobuf.FieldMask updateMask)
Updates an existing listing.Listing
updateListing(UpdateListingRequest request)
Updates an existing listing.com.google.api.gax.rpc.UnaryCallable<UpdateListingRequest,Listing>
updateListingCallable()
Updates an existing listing.
-
-
-
Constructor Detail
-
AnalyticsHubServiceClient
protected AnalyticsHubServiceClient(AnalyticsHubServiceSettings settings) throws IOException
Constructs an instance of AnalyticsHubServiceClient, 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.- Throws:
IOException
-
AnalyticsHubServiceClient
protected AnalyticsHubServiceClient(AnalyticsHubServiceStub stub)
-
-
Method Detail
-
create
public static final AnalyticsHubServiceClient create() throws IOException
Constructs an instance of AnalyticsHubServiceClient with default settings.- Throws:
IOException
-
create
public static final AnalyticsHubServiceClient create(AnalyticsHubServiceSettings settings) throws IOException
Constructs an instance of AnalyticsHubServiceClient, using the given settings. The channels are created based on the settings passed in, or defaults for any settings that are not set.- Throws:
IOException
-
create
public static final AnalyticsHubServiceClient create(AnalyticsHubServiceStub stub)
Constructs an instance of AnalyticsHubServiceClient, using the given stub for making calls. This is for advanced usage - prefer using create(AnalyticsHubServiceSettings).
-
getSettings
public final AnalyticsHubServiceSettings getSettings()
-
getStub
public AnalyticsHubServiceStub getStub()
-
listDataExchanges
public final AnalyticsHubServiceClient.ListDataExchangesPagedResponse listDataExchanges(LocationName parent)
Lists all data exchanges in a given project and location.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); for (DataExchange element : analyticsHubServiceClient.listDataExchanges(parent).iterateAll()) { // doThingsWith(element); } }
- Parameters:
parent
- Required. The parent resource path of the data exchanges. e.g. `projects/myproject/locations/US`.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
listDataExchanges
public final AnalyticsHubServiceClient.ListDataExchangesPagedResponse listDataExchanges(String parent)
Lists all data exchanges in a given project and location.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString(); for (DataExchange element : analyticsHubServiceClient.listDataExchanges(parent).iterateAll()) { // doThingsWith(element); } }
- Parameters:
parent
- Required. The parent resource path of the data exchanges. e.g. `projects/myproject/locations/US`.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
listDataExchanges
public final AnalyticsHubServiceClient.ListDataExchangesPagedResponse listDataExchanges(ListDataExchangesRequest request)
Lists all data exchanges in a given project and location.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { ListDataExchangesRequest request = ListDataExchangesRequest.newBuilder() .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString()) .setPageSize(883849137) .setPageToken("pageToken873572522") .build(); for (DataExchange element : analyticsHubServiceClient.listDataExchanges(request).iterateAll()) { // doThingsWith(element); } }
- Parameters:
request
- The request object containing all of the parameters for the API call.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
listDataExchangesPagedCallable
public final com.google.api.gax.rpc.UnaryCallable<ListDataExchangesRequest,AnalyticsHubServiceClient.ListDataExchangesPagedResponse> listDataExchangesPagedCallable()
Lists all data exchanges in a given project and location.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { ListDataExchangesRequest request = ListDataExchangesRequest.newBuilder() .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString()) .setPageSize(883849137) .setPageToken("pageToken873572522") .build(); ApiFuture<DataExchange> future = analyticsHubServiceClient.listDataExchangesPagedCallable().futureCall(request); // Do something. for (DataExchange element : future.get().iterateAll()) { // doThingsWith(element); } }
-
listDataExchangesCallable
public final com.google.api.gax.rpc.UnaryCallable<ListDataExchangesRequest,ListDataExchangesResponse> listDataExchangesCallable()
Lists all data exchanges in a given project and location.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { ListDataExchangesRequest request = ListDataExchangesRequest.newBuilder() .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString()) .setPageSize(883849137) .setPageToken("pageToken873572522") .build(); while (true) { ListDataExchangesResponse response = analyticsHubServiceClient.listDataExchangesCallable().call(request); for (DataExchange element : response.getDataExchangesList()) { // doThingsWith(element); } String nextPageToken = response.getNextPageToken(); if (!Strings.isNullOrEmpty(nextPageToken)) { request = request.toBuilder().setPageToken(nextPageToken).build(); } else { break; } } }
-
listOrgDataExchanges
public final AnalyticsHubServiceClient.ListOrgDataExchangesPagedResponse listOrgDataExchanges(String organization)
Lists all data exchanges from projects in a given organization and location.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { String organization = "organization1178922291"; for (DataExchange element : analyticsHubServiceClient.listOrgDataExchanges(organization).iterateAll()) { // doThingsWith(element); } }
- Parameters:
organization
- Required. The organization resource path of the projects containing DataExchanges. e.g. `organizations/myorg/locations/US`.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
listOrgDataExchanges
public final AnalyticsHubServiceClient.ListOrgDataExchangesPagedResponse listOrgDataExchanges(ListOrgDataExchangesRequest request)
Lists all data exchanges from projects in a given organization and location.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { ListOrgDataExchangesRequest request = ListOrgDataExchangesRequest.newBuilder() .setOrganization("organization1178922291") .setPageSize(883849137) .setPageToken("pageToken873572522") .build(); for (DataExchange element : analyticsHubServiceClient.listOrgDataExchanges(request).iterateAll()) { // doThingsWith(element); } }
- Parameters:
request
- The request object containing all of the parameters for the API call.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
listOrgDataExchangesPagedCallable
public final com.google.api.gax.rpc.UnaryCallable<ListOrgDataExchangesRequest,AnalyticsHubServiceClient.ListOrgDataExchangesPagedResponse> listOrgDataExchangesPagedCallable()
Lists all data exchanges from projects in a given organization and location.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { ListOrgDataExchangesRequest request = ListOrgDataExchangesRequest.newBuilder() .setOrganization("organization1178922291") .setPageSize(883849137) .setPageToken("pageToken873572522") .build(); ApiFuture<DataExchange> future = analyticsHubServiceClient.listOrgDataExchangesPagedCallable().futureCall(request); // Do something. for (DataExchange element : future.get().iterateAll()) { // doThingsWith(element); } }
-
listOrgDataExchangesCallable
public final com.google.api.gax.rpc.UnaryCallable<ListOrgDataExchangesRequest,ListOrgDataExchangesResponse> listOrgDataExchangesCallable()
Lists all data exchanges from projects in a given organization and location.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { ListOrgDataExchangesRequest request = ListOrgDataExchangesRequest.newBuilder() .setOrganization("organization1178922291") .setPageSize(883849137) .setPageToken("pageToken873572522") .build(); while (true) { ListOrgDataExchangesResponse response = analyticsHubServiceClient.listOrgDataExchangesCallable().call(request); for (DataExchange element : response.getDataExchangesList()) { // doThingsWith(element); } String nextPageToken = response.getNextPageToken(); if (!Strings.isNullOrEmpty(nextPageToken)) { request = request.toBuilder().setPageToken(nextPageToken).build(); } else { break; } } }
-
getDataExchange
public final DataExchange getDataExchange(DataExchangeName name)
Gets the details of a data exchange.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { DataExchangeName name = DataExchangeName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]"); DataExchange response = analyticsHubServiceClient.getDataExchange(name); }
- Parameters:
name
- Required. The resource name of the data exchange. e.g. `projects/myproject/locations/US/dataExchanges/123`.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
getDataExchange
public final DataExchange getDataExchange(String name)
Gets the details of a data exchange.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { String name = DataExchangeName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]").toString(); DataExchange response = analyticsHubServiceClient.getDataExchange(name); }
- Parameters:
name
- Required. The resource name of the data exchange. e.g. `projects/myproject/locations/US/dataExchanges/123`.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
getDataExchange
public final DataExchange getDataExchange(GetDataExchangeRequest request)
Gets the details of a data exchange.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { GetDataExchangeRequest request = GetDataExchangeRequest.newBuilder() .setName(DataExchangeName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]").toString()) .build(); DataExchange response = analyticsHubServiceClient.getDataExchange(request); }
- Parameters:
request
- The request object containing all of the parameters for the API call.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
getDataExchangeCallable
public final com.google.api.gax.rpc.UnaryCallable<GetDataExchangeRequest,DataExchange> getDataExchangeCallable()
Gets the details of a data exchange.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { GetDataExchangeRequest request = GetDataExchangeRequest.newBuilder() .setName(DataExchangeName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]").toString()) .build(); ApiFuture<DataExchange> future = analyticsHubServiceClient.getDataExchangeCallable().futureCall(request); // Do something. DataExchange response = future.get(); }
-
createDataExchange
public final DataExchange createDataExchange(LocationName parent, DataExchange dataExchange)
Creates a new data exchange.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); DataExchange dataExchange = DataExchange.newBuilder().build(); DataExchange response = analyticsHubServiceClient.createDataExchange(parent, dataExchange); }
- Parameters:
parent
- Required. The parent resource path of the data exchange. e.g. `projects/myproject/locations/US`.dataExchange
- Required. The data exchange to create.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
createDataExchange
public final DataExchange createDataExchange(String parent, DataExchange dataExchange)
Creates a new data exchange.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString(); DataExchange dataExchange = DataExchange.newBuilder().build(); DataExchange response = analyticsHubServiceClient.createDataExchange(parent, dataExchange); }
- Parameters:
parent
- Required. The parent resource path of the data exchange. e.g. `projects/myproject/locations/US`.dataExchange
- Required. The data exchange to create.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
createDataExchange
public final DataExchange createDataExchange(CreateDataExchangeRequest request)
Creates a new data exchange.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { CreateDataExchangeRequest request = CreateDataExchangeRequest.newBuilder() .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString()) .setDataExchangeId("dataExchangeId783243752") .setDataExchange(DataExchange.newBuilder().build()) .build(); DataExchange response = analyticsHubServiceClient.createDataExchange(request); }
- Parameters:
request
- The request object containing all of the parameters for the API call.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
createDataExchangeCallable
public final com.google.api.gax.rpc.UnaryCallable<CreateDataExchangeRequest,DataExchange> createDataExchangeCallable()
Creates a new data exchange.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { CreateDataExchangeRequest request = CreateDataExchangeRequest.newBuilder() .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString()) .setDataExchangeId("dataExchangeId783243752") .setDataExchange(DataExchange.newBuilder().build()) .build(); ApiFuture<DataExchange> future = analyticsHubServiceClient.createDataExchangeCallable().futureCall(request); // Do something. DataExchange response = future.get(); }
-
updateDataExchange
public final DataExchange updateDataExchange(DataExchange dataExchange, com.google.protobuf.FieldMask updateMask)
Updates an existing data exchange.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { DataExchange dataExchange = DataExchange.newBuilder().build(); FieldMask updateMask = FieldMask.newBuilder().build(); DataExchange response = analyticsHubServiceClient.updateDataExchange(dataExchange, updateMask); }
- Parameters:
dataExchange
- Required. The data exchange to update.updateMask
- Required. Field mask specifies the fields to update in the data exchange resource. The fields specified in the `updateMask` are relative to the resource and are not a full request.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
updateDataExchange
public final DataExchange updateDataExchange(UpdateDataExchangeRequest request)
Updates an existing data exchange.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { UpdateDataExchangeRequest request = UpdateDataExchangeRequest.newBuilder() .setUpdateMask(FieldMask.newBuilder().build()) .setDataExchange(DataExchange.newBuilder().build()) .build(); DataExchange response = analyticsHubServiceClient.updateDataExchange(request); }
- Parameters:
request
- The request object containing all of the parameters for the API call.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
updateDataExchangeCallable
public final com.google.api.gax.rpc.UnaryCallable<UpdateDataExchangeRequest,DataExchange> updateDataExchangeCallable()
Updates an existing data exchange.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { UpdateDataExchangeRequest request = UpdateDataExchangeRequest.newBuilder() .setUpdateMask(FieldMask.newBuilder().build()) .setDataExchange(DataExchange.newBuilder().build()) .build(); ApiFuture<DataExchange> future = analyticsHubServiceClient.updateDataExchangeCallable().futureCall(request); // Do something. DataExchange response = future.get(); }
-
deleteDataExchange
public final void deleteDataExchange(DataExchangeName name)
Deletes an existing data exchange.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { DataExchangeName name = DataExchangeName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]"); analyticsHubServiceClient.deleteDataExchange(name); }
- Parameters:
name
- Required. The full name of the data exchange resource that you want to delete. For example, `projects/myproject/locations/US/dataExchanges/123`.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
deleteDataExchange
public final void deleteDataExchange(String name)
Deletes an existing data exchange.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { String name = DataExchangeName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]").toString(); analyticsHubServiceClient.deleteDataExchange(name); }
- Parameters:
name
- Required. The full name of the data exchange resource that you want to delete. For example, `projects/myproject/locations/US/dataExchanges/123`.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
deleteDataExchange
public final void deleteDataExchange(DeleteDataExchangeRequest request)
Deletes an existing data exchange.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { DeleteDataExchangeRequest request = DeleteDataExchangeRequest.newBuilder() .setName(DataExchangeName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]").toString()) .build(); analyticsHubServiceClient.deleteDataExchange(request); }
- Parameters:
request
- The request object containing all of the parameters for the API call.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
deleteDataExchangeCallable
public final com.google.api.gax.rpc.UnaryCallable<DeleteDataExchangeRequest,com.google.protobuf.Empty> deleteDataExchangeCallable()
Deletes an existing data exchange.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { DeleteDataExchangeRequest request = DeleteDataExchangeRequest.newBuilder() .setName(DataExchangeName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]").toString()) .build(); ApiFuture<Empty> future = analyticsHubServiceClient.deleteDataExchangeCallable().futureCall(request); // Do something. future.get(); }
-
listListings
public final AnalyticsHubServiceClient.ListListingsPagedResponse listListings(DataExchangeName parent)
Lists all listings in a given project and location.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { DataExchangeName parent = DataExchangeName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]"); for (Listing element : analyticsHubServiceClient.listListings(parent).iterateAll()) { // doThingsWith(element); } }
- Parameters:
parent
- Required. The parent resource path of the listing. e.g. `projects/myproject/locations/US/dataExchanges/123`.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
listListings
public final AnalyticsHubServiceClient.ListListingsPagedResponse listListings(String parent)
Lists all listings in a given project and location.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { String parent = DataExchangeName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]").toString(); for (Listing element : analyticsHubServiceClient.listListings(parent).iterateAll()) { // doThingsWith(element); } }
- Parameters:
parent
- Required. The parent resource path of the listing. e.g. `projects/myproject/locations/US/dataExchanges/123`.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
listListings
public final AnalyticsHubServiceClient.ListListingsPagedResponse listListings(ListListingsRequest request)
Lists all listings in a given project and location.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { ListListingsRequest request = ListListingsRequest.newBuilder() .setParent( DataExchangeName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]").toString()) .setPageSize(883849137) .setPageToken("pageToken873572522") .build(); for (Listing element : analyticsHubServiceClient.listListings(request).iterateAll()) { // doThingsWith(element); } }
- Parameters:
request
- The request object containing all of the parameters for the API call.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
listListingsPagedCallable
public final com.google.api.gax.rpc.UnaryCallable<ListListingsRequest,AnalyticsHubServiceClient.ListListingsPagedResponse> listListingsPagedCallable()
Lists all listings in a given project and location.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { ListListingsRequest request = ListListingsRequest.newBuilder() .setParent( DataExchangeName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]").toString()) .setPageSize(883849137) .setPageToken("pageToken873572522") .build(); ApiFuture<Listing> future = analyticsHubServiceClient.listListingsPagedCallable().futureCall(request); // Do something. for (Listing element : future.get().iterateAll()) { // doThingsWith(element); } }
-
listListingsCallable
public final com.google.api.gax.rpc.UnaryCallable<ListListingsRequest,ListListingsResponse> listListingsCallable()
Lists all listings in a given project and location.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { ListListingsRequest request = ListListingsRequest.newBuilder() .setParent( DataExchangeName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]").toString()) .setPageSize(883849137) .setPageToken("pageToken873572522") .build(); while (true) { ListListingsResponse response = analyticsHubServiceClient.listListingsCallable().call(request); for (Listing element : response.getListingsList()) { // doThingsWith(element); } String nextPageToken = response.getNextPageToken(); if (!Strings.isNullOrEmpty(nextPageToken)) { request = request.toBuilder().setPageToken(nextPageToken).build(); } else { break; } } }
-
getListing
public final Listing getListing(ListingName name)
Gets the details of a listing.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { ListingName name = ListingName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]", "[LISTING]"); Listing response = analyticsHubServiceClient.getListing(name); }
- Parameters:
name
- Required. The resource name of the listing. e.g. `projects/myproject/locations/US/dataExchanges/123/listings/456`.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
getListing
public final Listing getListing(String name)
Gets the details of a listing.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { String name = ListingName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]", "[LISTING]").toString(); Listing response = analyticsHubServiceClient.getListing(name); }
- Parameters:
name
- Required. The resource name of the listing. e.g. `projects/myproject/locations/US/dataExchanges/123/listings/456`.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
getListing
public final Listing getListing(GetListingRequest request)
Gets the details of a listing.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { GetListingRequest request = GetListingRequest.newBuilder() .setName( ListingName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]", "[LISTING]") .toString()) .build(); Listing response = analyticsHubServiceClient.getListing(request); }
- Parameters:
request
- The request object containing all of the parameters for the API call.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
getListingCallable
public final com.google.api.gax.rpc.UnaryCallable<GetListingRequest,Listing> getListingCallable()
Gets the details of a listing.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { GetListingRequest request = GetListingRequest.newBuilder() .setName( ListingName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]", "[LISTING]") .toString()) .build(); ApiFuture<Listing> future = analyticsHubServiceClient.getListingCallable().futureCall(request); // Do something. Listing response = future.get(); }
-
createListing
public final Listing createListing(DataExchangeName parent, Listing listing)
Creates a new listing.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { DataExchangeName parent = DataExchangeName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]"); Listing listing = Listing.newBuilder().build(); Listing response = analyticsHubServiceClient.createListing(parent, listing); }
- Parameters:
parent
- Required. The parent resource path of the listing. e.g. `projects/myproject/locations/US/dataExchanges/123`.listing
- Required. The listing to create.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
createListing
public final Listing createListing(String parent, Listing listing)
Creates a new listing.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { String parent = DataExchangeName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]").toString(); Listing listing = Listing.newBuilder().build(); Listing response = analyticsHubServiceClient.createListing(parent, listing); }
- Parameters:
parent
- Required. The parent resource path of the listing. e.g. `projects/myproject/locations/US/dataExchanges/123`.listing
- Required. The listing to create.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
createListing
public final Listing createListing(CreateListingRequest request)
Creates a new listing.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { CreateListingRequest request = CreateListingRequest.newBuilder() .setParent( DataExchangeName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]").toString()) .setListingId("listingId-1215024449") .setListing(Listing.newBuilder().build()) .build(); Listing response = analyticsHubServiceClient.createListing(request); }
- Parameters:
request
- The request object containing all of the parameters for the API call.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
createListingCallable
public final com.google.api.gax.rpc.UnaryCallable<CreateListingRequest,Listing> createListingCallable()
Creates a new listing.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { CreateListingRequest request = CreateListingRequest.newBuilder() .setParent( DataExchangeName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]").toString()) .setListingId("listingId-1215024449") .setListing(Listing.newBuilder().build()) .build(); ApiFuture<Listing> future = analyticsHubServiceClient.createListingCallable().futureCall(request); // Do something. Listing response = future.get(); }
-
updateListing
public final Listing updateListing(Listing listing, com.google.protobuf.FieldMask updateMask)
Updates an existing listing.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { Listing listing = Listing.newBuilder().build(); FieldMask updateMask = FieldMask.newBuilder().build(); Listing response = analyticsHubServiceClient.updateListing(listing, updateMask); }
- Parameters:
listing
- Required. The listing to update.updateMask
- Required. Field mask specifies the fields to update in the listing resource. The fields specified in the `updateMask` are relative to the resource and are not a full request.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
updateListing
public final Listing updateListing(UpdateListingRequest request)
Updates an existing listing.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { UpdateListingRequest request = UpdateListingRequest.newBuilder() .setUpdateMask(FieldMask.newBuilder().build()) .setListing(Listing.newBuilder().build()) .build(); Listing response = analyticsHubServiceClient.updateListing(request); }
- Parameters:
request
- The request object containing all of the parameters for the API call.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
updateListingCallable
public final com.google.api.gax.rpc.UnaryCallable<UpdateListingRequest,Listing> updateListingCallable()
Updates an existing listing.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { UpdateListingRequest request = UpdateListingRequest.newBuilder() .setUpdateMask(FieldMask.newBuilder().build()) .setListing(Listing.newBuilder().build()) .build(); ApiFuture<Listing> future = analyticsHubServiceClient.updateListingCallable().futureCall(request); // Do something. Listing response = future.get(); }
-
deleteListing
public final void deleteListing(ListingName name)
Deletes a listing.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { ListingName name = ListingName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]", "[LISTING]"); analyticsHubServiceClient.deleteListing(name); }
- Parameters:
name
- Required. Resource name of the listing to delete. e.g. `projects/myproject/locations/US/dataExchanges/123/listings/456`.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
deleteListing
public final void deleteListing(String name)
Deletes a listing.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { String name = ListingName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]", "[LISTING]").toString(); analyticsHubServiceClient.deleteListing(name); }
- Parameters:
name
- Required. Resource name of the listing to delete. e.g. `projects/myproject/locations/US/dataExchanges/123/listings/456`.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
deleteListing
public final void deleteListing(DeleteListingRequest request)
Deletes a listing.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { DeleteListingRequest request = DeleteListingRequest.newBuilder() .setName( ListingName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]", "[LISTING]") .toString()) .build(); analyticsHubServiceClient.deleteListing(request); }
- Parameters:
request
- The request object containing all of the parameters for the API call.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
deleteListingCallable
public final com.google.api.gax.rpc.UnaryCallable<DeleteListingRequest,com.google.protobuf.Empty> deleteListingCallable()
Deletes a listing.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { DeleteListingRequest request = DeleteListingRequest.newBuilder() .setName( ListingName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]", "[LISTING]") .toString()) .build(); ApiFuture<Empty> future = analyticsHubServiceClient.deleteListingCallable().futureCall(request); // Do something. future.get(); }
-
subscribeListing
public final SubscribeListingResponse subscribeListing(ListingName name)
Subscribes to a listing.Currently, with Analytics Hub, you can create listings that reference only BigQuery datasets. Upon subscription to a listing for a BigQuery dataset, Analytics Hub creates a linked dataset in the subscriber's project.
Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { ListingName name = ListingName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]", "[LISTING]"); SubscribeListingResponse response = analyticsHubServiceClient.subscribeListing(name); }
- Parameters:
name
- Required. Resource name of the listing that you want to subscribe to. e.g. `projects/myproject/locations/US/dataExchanges/123/listings/456`.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
subscribeListing
public final SubscribeListingResponse subscribeListing(String name)
Subscribes to a listing.Currently, with Analytics Hub, you can create listings that reference only BigQuery datasets. Upon subscription to a listing for a BigQuery dataset, Analytics Hub creates a linked dataset in the subscriber's project.
Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { String name = ListingName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]", "[LISTING]").toString(); SubscribeListingResponse response = analyticsHubServiceClient.subscribeListing(name); }
- Parameters:
name
- Required. Resource name of the listing that you want to subscribe to. e.g. `projects/myproject/locations/US/dataExchanges/123/listings/456`.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
subscribeListing
public final SubscribeListingResponse subscribeListing(SubscribeListingRequest request)
Subscribes to a listing.Currently, with Analytics Hub, you can create listings that reference only BigQuery datasets. Upon subscription to a listing for a BigQuery dataset, Analytics Hub creates a linked dataset in the subscriber's project.
Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { SubscribeListingRequest request = SubscribeListingRequest.newBuilder() .setName( ListingName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]", "[LISTING]") .toString()) .build(); SubscribeListingResponse response = analyticsHubServiceClient.subscribeListing(request); }
- Parameters:
request
- The request object containing all of the parameters for the API call.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
subscribeListingCallable
public final com.google.api.gax.rpc.UnaryCallable<SubscribeListingRequest,SubscribeListingResponse> subscribeListingCallable()
Subscribes to a listing.Currently, with Analytics Hub, you can create listings that reference only BigQuery datasets. Upon subscription to a listing for a BigQuery dataset, Analytics Hub creates a linked dataset in the subscriber's project.
Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { SubscribeListingRequest request = SubscribeListingRequest.newBuilder() .setName( ListingName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]", "[LISTING]") .toString()) .build(); ApiFuture<SubscribeListingResponse> future = analyticsHubServiceClient.subscribeListingCallable().futureCall(request); // Do something. SubscribeListingResponse response = future.get(); }
-
getIamPolicy
public final com.google.iam.v1.Policy getIamPolicy(com.google.iam.v1.GetIamPolicyRequest request)
Gets the IAM policy.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { GetIamPolicyRequest request = GetIamPolicyRequest.newBuilder() .setResource( DataExchangeName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]").toString()) .setOptions(GetPolicyOptions.newBuilder().build()) .build(); Policy response = analyticsHubServiceClient.getIamPolicy(request); }
- Parameters:
request
- The request object containing all of the parameters for the API call.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
getIamPolicyCallable
public final com.google.api.gax.rpc.UnaryCallable<com.google.iam.v1.GetIamPolicyRequest,com.google.iam.v1.Policy> getIamPolicyCallable()
Gets the IAM policy.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { GetIamPolicyRequest request = GetIamPolicyRequest.newBuilder() .setResource( DataExchangeName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]").toString()) .setOptions(GetPolicyOptions.newBuilder().build()) .build(); ApiFuture<Policy> future = analyticsHubServiceClient.getIamPolicyCallable().futureCall(request); // Do something. Policy response = future.get(); }
-
setIamPolicy
public final com.google.iam.v1.Policy setIamPolicy(com.google.iam.v1.SetIamPolicyRequest request)
Sets the IAM policy.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { SetIamPolicyRequest request = SetIamPolicyRequest.newBuilder() .setResource( DataExchangeName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]").toString()) .setPolicy(Policy.newBuilder().build()) .setUpdateMask(FieldMask.newBuilder().build()) .build(); Policy response = analyticsHubServiceClient.setIamPolicy(request); }
- Parameters:
request
- The request object containing all of the parameters for the API call.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
setIamPolicyCallable
public final com.google.api.gax.rpc.UnaryCallable<com.google.iam.v1.SetIamPolicyRequest,com.google.iam.v1.Policy> setIamPolicyCallable()
Sets the IAM policy.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { SetIamPolicyRequest request = SetIamPolicyRequest.newBuilder() .setResource( DataExchangeName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]").toString()) .setPolicy(Policy.newBuilder().build()) .setUpdateMask(FieldMask.newBuilder().build()) .build(); ApiFuture<Policy> future = analyticsHubServiceClient.setIamPolicyCallable().futureCall(request); // Do something. Policy response = future.get(); }
-
testIamPermissions
public final com.google.iam.v1.TestIamPermissionsResponse testIamPermissions(com.google.iam.v1.TestIamPermissionsRequest request)
Returns the permissions that a caller has.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { TestIamPermissionsRequest request = TestIamPermissionsRequest.newBuilder() .setResource( DataExchangeName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]").toString()) .addAllPermissions(new ArrayList<String>()) .build(); TestIamPermissionsResponse response = analyticsHubServiceClient.testIamPermissions(request); }
- Parameters:
request
- The request object containing all of the parameters for the API call.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
testIamPermissionsCallable
public final com.google.api.gax.rpc.UnaryCallable<com.google.iam.v1.TestIamPermissionsRequest,com.google.iam.v1.TestIamPermissionsResponse> testIamPermissionsCallable()
Returns the permissions that a caller has.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { TestIamPermissionsRequest request = TestIamPermissionsRequest.newBuilder() .setResource( DataExchangeName.of("[PROJECT]", "[LOCATION]", "[DATA_EXCHANGE]").toString()) .addAllPermissions(new ArrayList<String>()) .build(); ApiFuture<TestIamPermissionsResponse> future = analyticsHubServiceClient.testIamPermissionsCallable().futureCall(request); // Do something. TestIamPermissionsResponse response = future.get(); }
-
listLocations
public final AnalyticsHubServiceClient.ListLocationsPagedResponse listLocations(com.google.cloud.location.ListLocationsRequest request)
Lists information about the supported locations for this service.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { ListLocationsRequest request = ListLocationsRequest.newBuilder() .setName("name3373707") .setFilter("filter-1274492040") .setPageSize(883849137) .setPageToken("pageToken873572522") .build(); for (Location element : analyticsHubServiceClient.listLocations(request).iterateAll()) { // doThingsWith(element); } }
- Parameters:
request
- The request object containing all of the parameters for the API call.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
listLocationsPagedCallable
public final com.google.api.gax.rpc.UnaryCallable<com.google.cloud.location.ListLocationsRequest,AnalyticsHubServiceClient.ListLocationsPagedResponse> listLocationsPagedCallable()
Lists information about the supported locations for this service.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { ListLocationsRequest request = ListLocationsRequest.newBuilder() .setName("name3373707") .setFilter("filter-1274492040") .setPageSize(883849137) .setPageToken("pageToken873572522") .build(); ApiFuture<Location> future = analyticsHubServiceClient.listLocationsPagedCallable().futureCall(request); // Do something. for (Location element : future.get().iterateAll()) { // doThingsWith(element); } }
-
listLocationsCallable
public final com.google.api.gax.rpc.UnaryCallable<com.google.cloud.location.ListLocationsRequest,com.google.cloud.location.ListLocationsResponse> listLocationsCallable()
Lists information about the supported locations for this service.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { ListLocationsRequest request = ListLocationsRequest.newBuilder() .setName("name3373707") .setFilter("filter-1274492040") .setPageSize(883849137) .setPageToken("pageToken873572522") .build(); while (true) { ListLocationsResponse response = analyticsHubServiceClient.listLocationsCallable().call(request); for (Location element : response.getLocationsList()) { // doThingsWith(element); } String nextPageToken = response.getNextPageToken(); if (!Strings.isNullOrEmpty(nextPageToken)) { request = request.toBuilder().setPageToken(nextPageToken).build(); } else { break; } } }
-
getLocation
public final com.google.cloud.location.Location getLocation(com.google.cloud.location.GetLocationRequest request)
Gets information about a location.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { GetLocationRequest request = GetLocationRequest.newBuilder().setName("name3373707").build(); Location response = analyticsHubServiceClient.getLocation(request); }
- Parameters:
request
- The request object containing all of the parameters for the API call.- Throws:
com.google.api.gax.rpc.ApiException
- if the remote call fails
-
getLocationCallable
public final com.google.api.gax.rpc.UnaryCallable<com.google.cloud.location.GetLocationRequest,com.google.cloud.location.Location> getLocationCallable()
Gets information about a location.Sample code:
// 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 (AnalyticsHubServiceClient analyticsHubServiceClient = AnalyticsHubServiceClient.create()) { GetLocationRequest request = GetLocationRequest.newBuilder().setName("name3373707").build(); ApiFuture<Location> future = analyticsHubServiceClient.getLocationCallable().futureCall(request); // Do something. Location response = future.get(); }
-
close
public final void close()
- Specified by:
close
in interfaceAutoCloseable
-
shutdown
public void shutdown()
- Specified by:
shutdown
in interfacecom.google.api.gax.core.BackgroundResource
-
isShutdown
public boolean isShutdown()
- Specified by:
isShutdown
in interfacecom.google.api.gax.core.BackgroundResource
-
isTerminated
public boolean isTerminated()
- Specified by:
isTerminated
in interfacecom.google.api.gax.core.BackgroundResource
-
shutdownNow
public void shutdownNow()
- Specified by:
shutdownNow
in interfacecom.google.api.gax.core.BackgroundResource
-
awaitTermination
public boolean awaitTermination(long duration, TimeUnit unit) throws InterruptedException
- Specified by:
awaitTermination
in interfacecom.google.api.gax.core.BackgroundResource
- Throws:
InterruptedException
-
-