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: + * + *
{@code
+ * try (ContentServiceClient contentServiceClient = ContentServiceClient.create()) {
+ * LakeName parent = LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]");
+ * Content content = Content.newBuilder().build();
+ * Content response = contentServiceClient.createContent(parent, content);
+ * }
+ * }
+ *
+ * Note: close() needs to be called on the ContentServiceClient 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: + * + *
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 ContentServiceSettings to + * create(). For example: + * + *
To customize credentials: + * + *
{@code
+ * ContentServiceSettings contentServiceSettings =
+ * ContentServiceSettings.newBuilder()
+ * .setCredentialsProvider(FixedCredentialsProvider.create(myCredentials))
+ * .build();
+ * ContentServiceClient contentServiceClient = ContentServiceClient.create(contentServiceSettings);
+ * }
+ *
+ * To customize the endpoint: + * + *
{@code
+ * ContentServiceSettings contentServiceSettings =
+ * ContentServiceSettings.newBuilder().setEndpoint(myEndpoint).build();
+ * ContentServiceClient contentServiceClient = ContentServiceClient.create(contentServiceSettings);
+ * }
+ *
+ * Please refer to the GitHub repository's samples for more quickstart code snippets. + */ +@Generated("by gapic-generator-java") +public class ContentServiceClient implements BackgroundResource { + private final ContentServiceSettings settings; + private final ContentServiceStub stub; + + /** Constructs an instance of ContentServiceClient with default settings. */ + public static final ContentServiceClient create() throws IOException { + return create(ContentServiceSettings.newBuilder().build()); + } + + /** + * Constructs an instance of ContentServiceClient, using the given settings. The channels are + * created based on the settings passed in, or defaults for any settings that are not set. + */ + public static final ContentServiceClient create(ContentServiceSettings settings) + throws IOException { + return new ContentServiceClient(settings); + } + + /** + * Constructs an instance of ContentServiceClient, using the given stub for making calls. This is + * for advanced usage - prefer using create(ContentServiceSettings). + */ + @BetaApi("A restructuring of stub classes is planned, so this may break in the future") + public static final ContentServiceClient create(ContentServiceStub stub) { + return new ContentServiceClient(stub); + } + + /** + * Constructs an instance of ContentServiceClient, 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. + */ + protected ContentServiceClient(ContentServiceSettings settings) throws IOException { + this.settings = settings; + this.stub = ((ContentServiceStubSettings) settings.getStubSettings()).createStub(); + } + + @BetaApi("A restructuring of stub classes is planned, so this may break in the future") + protected ContentServiceClient(ContentServiceStub stub) { + this.settings = null; + this.stub = stub; + } + + public final ContentServiceSettings getSettings() { + return settings; + } + + @BetaApi("A restructuring of stub classes is planned, so this may break in the future") + public ContentServiceStub getStub() { + return stub; + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Create a content. + * + *
Sample code: + * + *
{@code
+ * try (ContentServiceClient contentServiceClient = ContentServiceClient.create()) {
+ * LakeName parent = LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]");
+ * Content content = Content.newBuilder().build();
+ * Content response = contentServiceClient.createContent(parent, content);
+ * }
+ * }
+ *
+ * @param parent Required. The resource name of the parent lake:
+ * projects/{project_id}/locations/{location_id}/lakes/{lake_id}
+ * @param content Required. Content resource.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final Content createContent(LakeName parent, Content content) {
+ CreateContentRequest request =
+ CreateContentRequest.newBuilder()
+ .setParent(parent == null ? null : parent.toString())
+ .setContent(content)
+ .build();
+ return createContent(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Create a content.
+ *
+ * Sample code: + * + *
{@code
+ * try (ContentServiceClient contentServiceClient = ContentServiceClient.create()) {
+ * String parent = LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString();
+ * Content content = Content.newBuilder().build();
+ * Content response = contentServiceClient.createContent(parent, content);
+ * }
+ * }
+ *
+ * @param parent Required. The resource name of the parent lake:
+ * projects/{project_id}/locations/{location_id}/lakes/{lake_id}
+ * @param content Required. Content resource.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final Content createContent(String parent, Content content) {
+ CreateContentRequest request =
+ CreateContentRequest.newBuilder().setParent(parent).setContent(content).build();
+ return createContent(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Create a content.
+ *
+ * Sample code: + * + *
{@code
+ * try (ContentServiceClient contentServiceClient = ContentServiceClient.create()) {
+ * CreateContentRequest request =
+ * CreateContentRequest.newBuilder()
+ * .setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
+ * .setContent(Content.newBuilder().build())
+ * .setValidateOnly(true)
+ * .build();
+ * Content response = contentServiceClient.createContent(request);
+ * }
+ * }
+ *
+ * @param 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
+ */
+ public final Content createContent(CreateContentRequest request) {
+ return createContentCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Create a content.
+ *
+ * Sample code: + * + *
{@code
+ * try (ContentServiceClient contentServiceClient = ContentServiceClient.create()) {
+ * CreateContentRequest request =
+ * CreateContentRequest.newBuilder()
+ * .setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
+ * .setContent(Content.newBuilder().build())
+ * .setValidateOnly(true)
+ * .build();
+ * ApiFuture future = contentServiceClient.createContentCallable().futureCall(request);
+ * // Do something.
+ * Content response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallableSample code: + * + *
{@code
+ * try (ContentServiceClient contentServiceClient = ContentServiceClient.create()) {
+ * Content content = Content.newBuilder().build();
+ * FieldMask updateMask = FieldMask.newBuilder().build();
+ * Content response = contentServiceClient.updateContent(content, updateMask);
+ * }
+ * }
+ *
+ * @param content Required. Update description. Only fields specified in `update_mask` are
+ * updated.
+ * @param updateMask Required. Mask of fields to update.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final Content updateContent(Content content, FieldMask updateMask) {
+ UpdateContentRequest request =
+ UpdateContentRequest.newBuilder().setContent(content).setUpdateMask(updateMask).build();
+ return updateContent(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Update a content. Only supports full resource update.
+ *
+ * Sample code: + * + *
{@code
+ * try (ContentServiceClient contentServiceClient = ContentServiceClient.create()) {
+ * UpdateContentRequest request =
+ * UpdateContentRequest.newBuilder()
+ * .setUpdateMask(FieldMask.newBuilder().build())
+ * .setContent(Content.newBuilder().build())
+ * .setValidateOnly(true)
+ * .build();
+ * Content response = contentServiceClient.updateContent(request);
+ * }
+ * }
+ *
+ * @param 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
+ */
+ public final Content updateContent(UpdateContentRequest request) {
+ return updateContentCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Update a content. Only supports full resource update.
+ *
+ * Sample code: + * + *
{@code
+ * try (ContentServiceClient contentServiceClient = ContentServiceClient.create()) {
+ * UpdateContentRequest request =
+ * UpdateContentRequest.newBuilder()
+ * .setUpdateMask(FieldMask.newBuilder().build())
+ * .setContent(Content.newBuilder().build())
+ * .setValidateOnly(true)
+ * .build();
+ * ApiFuture future = contentServiceClient.updateContentCallable().futureCall(request);
+ * // Do something.
+ * Content response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallableSample code: + * + *
{@code
+ * try (ContentServiceClient contentServiceClient = ContentServiceClient.create()) {
+ * ContentName name = ContentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[CONTENT]");
+ * contentServiceClient.deleteContent(name);
+ * }
+ * }
+ *
+ * @param name Required. The resource name of the content:
+ * projects/{project_id}/locations/{location_id}/lakes/{lake_id}/content/{content_id}
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final void deleteContent(ContentName name) {
+ DeleteContentRequest request =
+ DeleteContentRequest.newBuilder().setName(name == null ? null : name.toString()).build();
+ deleteContent(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Delete a content.
+ *
+ * Sample code: + * + *
{@code
+ * try (ContentServiceClient contentServiceClient = ContentServiceClient.create()) {
+ * String name = ContentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[CONTENT]").toString();
+ * contentServiceClient.deleteContent(name);
+ * }
+ * }
+ *
+ * @param name Required. The resource name of the content:
+ * projects/{project_id}/locations/{location_id}/lakes/{lake_id}/content/{content_id}
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final void deleteContent(String name) {
+ DeleteContentRequest request = DeleteContentRequest.newBuilder().setName(name).build();
+ deleteContent(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Delete a content.
+ *
+ * Sample code: + * + *
{@code
+ * try (ContentServiceClient contentServiceClient = ContentServiceClient.create()) {
+ * DeleteContentRequest request =
+ * DeleteContentRequest.newBuilder()
+ * .setName(ContentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[CONTENT]").toString())
+ * .build();
+ * contentServiceClient.deleteContent(request);
+ * }
+ * }
+ *
+ * @param 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
+ */
+ public final void deleteContent(DeleteContentRequest request) {
+ deleteContentCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Delete a content.
+ *
+ * Sample code: + * + *
{@code
+ * try (ContentServiceClient contentServiceClient = ContentServiceClient.create()) {
+ * DeleteContentRequest request =
+ * DeleteContentRequest.newBuilder()
+ * .setName(ContentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[CONTENT]").toString())
+ * .build();
+ * ApiFuture future = contentServiceClient.deleteContentCallable().futureCall(request);
+ * // Do something.
+ * future.get();
+ * }
+ * }
+ */
+ public final UnaryCallableSample code: + * + *
{@code
+ * try (ContentServiceClient contentServiceClient = ContentServiceClient.create()) {
+ * ContentName name = ContentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[CONTENT]");
+ * Content response = contentServiceClient.getContent(name);
+ * }
+ * }
+ *
+ * @param name Required. The resource name of the content:
+ * projects/{project_id}/locations/{location_id}/lakes/{lake_id}/content/{content_id}
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final Content getContent(ContentName name) {
+ GetContentRequest request =
+ GetContentRequest.newBuilder().setName(name == null ? null : name.toString()).build();
+ return getContent(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Get a content resource.
+ *
+ * Sample code: + * + *
{@code
+ * try (ContentServiceClient contentServiceClient = ContentServiceClient.create()) {
+ * String name = ContentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[CONTENT]").toString();
+ * Content response = contentServiceClient.getContent(name);
+ * }
+ * }
+ *
+ * @param name Required. The resource name of the content:
+ * projects/{project_id}/locations/{location_id}/lakes/{lake_id}/content/{content_id}
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final Content getContent(String name) {
+ GetContentRequest request = GetContentRequest.newBuilder().setName(name).build();
+ return getContent(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Get a content resource.
+ *
+ * Sample code: + * + *
{@code
+ * try (ContentServiceClient contentServiceClient = ContentServiceClient.create()) {
+ * GetContentRequest request =
+ * GetContentRequest.newBuilder()
+ * .setName(ContentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[CONTENT]").toString())
+ * .build();
+ * Content response = contentServiceClient.getContent(request);
+ * }
+ * }
+ *
+ * @param 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
+ */
+ public final Content getContent(GetContentRequest request) {
+ return getContentCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Get a content resource.
+ *
+ * Sample code: + * + *
{@code
+ * try (ContentServiceClient contentServiceClient = ContentServiceClient.create()) {
+ * GetContentRequest request =
+ * GetContentRequest.newBuilder()
+ * .setName(ContentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[CONTENT]").toString())
+ * .build();
+ * ApiFuture future = contentServiceClient.getContentCallable().futureCall(request);
+ * // Do something.
+ * Content response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallableSample code: + * + *
{@code
+ * try (ContentServiceClient contentServiceClient = ContentServiceClient.create()) {
+ * LakeName parent = LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]");
+ * for (Content element : contentServiceClient.listContent(parent).iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ *
+ * @param parent Required. The resource name of the parent lake:
+ * projects/{project_id}/locations/{location_id}/lakes/{lake_id}
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final ListContentPagedResponse listContent(LakeName parent) {
+ ListContentRequest request =
+ ListContentRequest.newBuilder()
+ .setParent(parent == null ? null : parent.toString())
+ .build();
+ return listContent(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * List content.
+ *
+ * Sample code: + * + *
{@code
+ * try (ContentServiceClient contentServiceClient = ContentServiceClient.create()) {
+ * String parent = LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString();
+ * for (Content element : contentServiceClient.listContent(parent).iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ *
+ * @param parent Required. The resource name of the parent lake:
+ * projects/{project_id}/locations/{location_id}/lakes/{lake_id}
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final ListContentPagedResponse listContent(String parent) {
+ ListContentRequest request = ListContentRequest.newBuilder().setParent(parent).build();
+ return listContent(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * List content.
+ *
+ * Sample code: + * + *
{@code
+ * try (ContentServiceClient contentServiceClient = ContentServiceClient.create()) {
+ * ListContentRequest request =
+ * ListContentRequest.newBuilder()
+ * .setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .setFilter("filter-1274492040")
+ * .build();
+ * for (Content element : contentServiceClient.listContent(request).iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ *
+ * @param 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
+ */
+ public final ListContentPagedResponse listContent(ListContentRequest request) {
+ return listContentPagedCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * List content.
+ *
+ * Sample code: + * + *
{@code
+ * try (ContentServiceClient contentServiceClient = ContentServiceClient.create()) {
+ * ListContentRequest request =
+ * ListContentRequest.newBuilder()
+ * .setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .setFilter("filter-1274492040")
+ * .build();
+ * ApiFuture future =
+ * contentServiceClient.listContentPagedCallable().futureCall(request);
+ * // Do something.
+ * for (Content element : future.get().iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ */
+ public final UnaryCallableSample code: + * + *
{@code
+ * try (ContentServiceClient contentServiceClient = ContentServiceClient.create()) {
+ * ListContentRequest request =
+ * ListContentRequest.newBuilder()
+ * .setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .setFilter("filter-1274492040")
+ * .build();
+ * while (true) {
+ * ListContentResponse response = contentServiceClient.listContentCallable().call(request);
+ * for (Content element : response.getResponsesList()) {
+ * // doThingsWith(element);
+ * }
+ * String nextPageToken = response.getNextPageToken();
+ * if (!Strings.isNullOrEmpty(nextPageToken)) {
+ * request = request.toBuilder().setPageToken(nextPageToken).build();
+ * } else {
+ * break;
+ * }
+ * }
+ * }
+ * }
+ */
+ public final UnaryCallableThe default instance has everything set to sensible defaults: + * + *
The builder of this class is recursive, so contained classes are themselves builders. When + * build() is called, the tree of builders is called to create the complete settings object. + * + *
For example, to set the total timeout of createContent to 30 seconds: + * + *
{@code
+ * ContentServiceSettings.Builder contentServiceSettingsBuilder =
+ * ContentServiceSettings.newBuilder();
+ * contentServiceSettingsBuilder
+ * .createContentSettings()
+ * .setRetrySettings(
+ * contentServiceSettingsBuilder
+ * .createContentSettings()
+ * .getRetrySettings()
+ * .toBuilder()
+ * .setTotalTimeout(Duration.ofSeconds(30))
+ * .build());
+ * ContentServiceSettings contentServiceSettings = contentServiceSettingsBuilder.build();
+ * }
+ */
+@Generated("by gapic-generator-java")
+public class ContentServiceSettings extends ClientSettingsNote: This method does not support applying settings to streaming methods.
+ */
+ public Builder applyToAllUnaryMethods(
+ ApiFunction Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * The builder of this class is recursive, so contained classes are themselves builders. When
* build() is called, the tree of builders is called to create the complete settings object.
*
- * For example, to set the total timeout of getEntity to 30 seconds:
+ * For example, to set the total timeout of createEntity to 30 seconds:
*
* The interfaces provided are listed below, along with usage samples.
*
+ * ======================= ContentServiceClient =======================
+ *
+ * Service Description: ContentService manages Notebook and SQL Scripts for Dataplex.
+ *
+ * Sample for ContentServiceClient:
+ *
+ * ======================= MetadataServiceClient =======================
*
* Service Description: Metadata service manages metadata resources such as tables, filesets and
@@ -28,8 +42,9 @@
*
* This class is for advanced usage and reflects the underlying API directly.
+ */
+@Generated("by gapic-generator-java")
+public abstract class ContentServiceStub implements BackgroundResource {
+
+ public UnaryCallable The default instance has everything set to sensible defaults:
+ *
+ * The builder of this class is recursive, so contained classes are themselves builders. When
+ * build() is called, the tree of builders is called to create the complete settings object.
+ *
+ * For example, to set the total timeout of createContent to 30 seconds:
+ *
+ * Note: This method does not support applying settings to streaming methods.
+ */
+ public Builder applyToAllUnaryMethods(
+ ApiFunction{@code
+ * try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
+ * LakeName parent = LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]");
+ * Environment environment = Environment.newBuilder().build();
+ * String environmentId = "environmentId-950205810";
+ * Environment response =
+ * dataplexServiceClient.createEnvironmentAsync(parent, environment, environmentId).get();
+ * }
+ * }
+ *
+ * @param parent Required. The resource name of the parent lake:
+ * projects/{project_id}/locations/{location_id}/lakes/{lake_id}
+ * @param environment Required. Environment resource.
+ * @param environmentId Required. Environment identifier.
+ *
+ *
+ *
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final OperationFuture{@code
+ * try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
+ * String parent = LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString();
+ * Environment environment = Environment.newBuilder().build();
+ * String environmentId = "environmentId-950205810";
+ * Environment response =
+ * dataplexServiceClient.createEnvironmentAsync(parent, environment, environmentId).get();
+ * }
+ * }
+ *
+ * @param parent Required. The resource name of the parent lake:
+ * projects/{project_id}/locations/{location_id}/lakes/{lake_id}
+ * @param environment Required. Environment resource.
+ * @param environmentId Required. Environment identifier.
+ *
+ *
+ *
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final OperationFuture{@code
+ * try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
+ * CreateEnvironmentRequest request =
+ * CreateEnvironmentRequest.newBuilder()
+ * .setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
+ * .setEnvironmentId("environmentId-950205810")
+ * .setEnvironment(Environment.newBuilder().build())
+ * .setValidateOnly(true)
+ * .build();
+ * Environment response = dataplexServiceClient.createEnvironmentAsync(request).get();
+ * }
+ * }
+ *
+ * @param 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
+ */
+ public final OperationFuture{@code
+ * try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
+ * CreateEnvironmentRequest request =
+ * CreateEnvironmentRequest.newBuilder()
+ * .setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
+ * .setEnvironmentId("environmentId-950205810")
+ * .setEnvironment(Environment.newBuilder().build())
+ * .setValidateOnly(true)
+ * .build();
+ * OperationFuture
+ */
+ public final OperationCallable{@code
+ * try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
+ * CreateEnvironmentRequest request =
+ * CreateEnvironmentRequest.newBuilder()
+ * .setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
+ * .setEnvironmentId("environmentId-950205810")
+ * .setEnvironment(Environment.newBuilder().build())
+ * .setValidateOnly(true)
+ * .build();
+ * ApiFuture
+ */
+ public final UnaryCallable{@code
+ * try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
+ * Environment environment = Environment.newBuilder().build();
+ * FieldMask updateMask = FieldMask.newBuilder().build();
+ * Environment response =
+ * dataplexServiceClient.updateEnvironmentAsync(environment, updateMask).get();
+ * }
+ * }
+ *
+ * @param environment Required. Update description. Only fields specified in `update_mask` are
+ * updated.
+ * @param updateMask Required. Mask of fields to update.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final OperationFuture{@code
+ * try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
+ * UpdateEnvironmentRequest request =
+ * UpdateEnvironmentRequest.newBuilder()
+ * .setUpdateMask(FieldMask.newBuilder().build())
+ * .setEnvironment(Environment.newBuilder().build())
+ * .setValidateOnly(true)
+ * .build();
+ * Environment response = dataplexServiceClient.updateEnvironmentAsync(request).get();
+ * }
+ * }
+ *
+ * @param 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
+ */
+ public final OperationFuture{@code
+ * try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
+ * UpdateEnvironmentRequest request =
+ * UpdateEnvironmentRequest.newBuilder()
+ * .setUpdateMask(FieldMask.newBuilder().build())
+ * .setEnvironment(Environment.newBuilder().build())
+ * .setValidateOnly(true)
+ * .build();
+ * OperationFuture
+ */
+ public final OperationCallable{@code
+ * try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
+ * UpdateEnvironmentRequest request =
+ * UpdateEnvironmentRequest.newBuilder()
+ * .setUpdateMask(FieldMask.newBuilder().build())
+ * .setEnvironment(Environment.newBuilder().build())
+ * .setValidateOnly(true)
+ * .build();
+ * ApiFuture
+ */
+ public final UnaryCallable{@code
+ * try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
+ * EnvironmentName name =
+ * EnvironmentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ENVIRONMENT]");
+ * dataplexServiceClient.deleteEnvironmentAsync(name).get();
+ * }
+ * }
+ *
+ * @param name Required. The resource name of the environment:
+ * projects/{project_id}/locations/{location_id}/lakes/{lake_id}/environments/{environment_id}`
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final OperationFuture{@code
+ * try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
+ * String name =
+ * EnvironmentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ENVIRONMENT]").toString();
+ * dataplexServiceClient.deleteEnvironmentAsync(name).get();
+ * }
+ * }
+ *
+ * @param name Required. The resource name of the environment:
+ * projects/{project_id}/locations/{location_id}/lakes/{lake_id}/environments/{environment_id}`
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final OperationFuture{@code
+ * try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
+ * DeleteEnvironmentRequest request =
+ * DeleteEnvironmentRequest.newBuilder()
+ * .setName(
+ * EnvironmentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ENVIRONMENT]")
+ * .toString())
+ * .build();
+ * dataplexServiceClient.deleteEnvironmentAsync(request).get();
+ * }
+ * }
+ *
+ * @param 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
+ */
+ public final OperationFuture{@code
+ * try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
+ * DeleteEnvironmentRequest request =
+ * DeleteEnvironmentRequest.newBuilder()
+ * .setName(
+ * EnvironmentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ENVIRONMENT]")
+ * .toString())
+ * .build();
+ * OperationFuture
+ */
+ public final OperationCallable{@code
+ * try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
+ * DeleteEnvironmentRequest request =
+ * DeleteEnvironmentRequest.newBuilder()
+ * .setName(
+ * EnvironmentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ENVIRONMENT]")
+ * .toString())
+ * .build();
+ * ApiFuture
+ */
+ public final UnaryCallable{@code
+ * try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
+ * LakeName parent = LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]");
+ * for (Environment element : dataplexServiceClient.listEnvironments(parent).iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ *
+ * @param parent Required. The resource name of the parent lake:
+ * projects/{project_id}/locations/{location_id}/lakes/{lake_id}
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final ListEnvironmentsPagedResponse listEnvironments(LakeName parent) {
+ ListEnvironmentsRequest request =
+ ListEnvironmentsRequest.newBuilder()
+ .setParent(parent == null ? null : parent.toString())
+ .build();
+ return listEnvironments(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists environments under the given lake.
+ *
+ * {@code
+ * try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
+ * String parent = LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString();
+ * for (Environment element : dataplexServiceClient.listEnvironments(parent).iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ *
+ * @param parent Required. The resource name of the parent lake:
+ * projects/{project_id}/locations/{location_id}/lakes/{lake_id}
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final ListEnvironmentsPagedResponse listEnvironments(String parent) {
+ ListEnvironmentsRequest request =
+ ListEnvironmentsRequest.newBuilder().setParent(parent).build();
+ return listEnvironments(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists environments under the given lake.
+ *
+ * {@code
+ * try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
+ * ListEnvironmentsRequest request =
+ * ListEnvironmentsRequest.newBuilder()
+ * .setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .setFilter("filter-1274492040")
+ * .setOrderBy("orderBy-1207110587")
+ * .build();
+ * for (Environment element : dataplexServiceClient.listEnvironments(request).iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ *
+ * @param 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
+ */
+ public final ListEnvironmentsPagedResponse listEnvironments(ListEnvironmentsRequest request) {
+ return listEnvironmentsPagedCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists environments under the given lake.
+ *
+ * {@code
+ * try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
+ * ListEnvironmentsRequest request =
+ * ListEnvironmentsRequest.newBuilder()
+ * .setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .setFilter("filter-1274492040")
+ * .setOrderBy("orderBy-1207110587")
+ * .build();
+ * ApiFuture
+ */
+ public final UnaryCallable{@code
+ * try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
+ * ListEnvironmentsRequest request =
+ * ListEnvironmentsRequest.newBuilder()
+ * .setParent(LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]").toString())
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .setFilter("filter-1274492040")
+ * .setOrderBy("orderBy-1207110587")
+ * .build();
+ * while (true) {
+ * ListEnvironmentsResponse response =
+ * dataplexServiceClient.listEnvironmentsCallable().call(request);
+ * for (Environment element : response.getResponsesList()) {
+ * // doThingsWith(element);
+ * }
+ * String nextPageToken = response.getNextPageToken();
+ * if (!Strings.isNullOrEmpty(nextPageToken)) {
+ * request = request.toBuilder().setPageToken(nextPageToken).build();
+ * } else {
+ * break;
+ * }
+ * }
+ * }
+ * }
+ */
+ public final UnaryCallable{@code
+ * try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
+ * EnvironmentName name =
+ * EnvironmentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ENVIRONMENT]");
+ * Environment response = dataplexServiceClient.getEnvironment(name);
+ * }
+ * }
+ *
+ * @param name Required. The resource name of the environment:
+ * projects/{project_id}/locations/{location_id}/lakes/{lake_id}/environments/{environment_id}
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final Environment getEnvironment(EnvironmentName name) {
+ GetEnvironmentRequest request =
+ GetEnvironmentRequest.newBuilder().setName(name == null ? null : name.toString()).build();
+ return getEnvironment(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Get environment resource.
+ *
+ * {@code
+ * try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
+ * String name =
+ * EnvironmentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ENVIRONMENT]").toString();
+ * Environment response = dataplexServiceClient.getEnvironment(name);
+ * }
+ * }
+ *
+ * @param name Required. The resource name of the environment:
+ * projects/{project_id}/locations/{location_id}/lakes/{lake_id}/environments/{environment_id}
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final Environment getEnvironment(String name) {
+ GetEnvironmentRequest request = GetEnvironmentRequest.newBuilder().setName(name).build();
+ return getEnvironment(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Get environment resource.
+ *
+ * {@code
+ * try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
+ * GetEnvironmentRequest request =
+ * GetEnvironmentRequest.newBuilder()
+ * .setName(
+ * EnvironmentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ENVIRONMENT]")
+ * .toString())
+ * .build();
+ * Environment response = dataplexServiceClient.getEnvironment(request);
+ * }
+ * }
+ *
+ * @param 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
+ */
+ public final Environment getEnvironment(GetEnvironmentRequest request) {
+ return getEnvironmentCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Get environment resource.
+ *
+ * {@code
+ * try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
+ * GetEnvironmentRequest request =
+ * GetEnvironmentRequest.newBuilder()
+ * .setName(
+ * EnvironmentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ENVIRONMENT]")
+ * .toString())
+ * .build();
+ * ApiFuture
+ */
+ public final UnaryCallable{@code
+ * try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
+ * EnvironmentName parent =
+ * EnvironmentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ENVIRONMENT]");
+ * for (Session element : dataplexServiceClient.listSessions(parent).iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ *
+ * @param parent Required. The resource name of the parent environment:
+ * projects/{project_number}/locations/{location_id}/lakes/{lake_id}/environment/{environment_id}
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final ListSessionsPagedResponse listSessions(EnvironmentName parent) {
+ ListSessionsRequest request =
+ ListSessionsRequest.newBuilder()
+ .setParent(parent == null ? null : parent.toString())
+ .build();
+ return listSessions(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists session resources in an environment.
+ *
+ * {@code
+ * try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
+ * String parent =
+ * EnvironmentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ENVIRONMENT]").toString();
+ * for (Session element : dataplexServiceClient.listSessions(parent).iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ *
+ * @param parent Required. The resource name of the parent environment:
+ * projects/{project_number}/locations/{location_id}/lakes/{lake_id}/environment/{environment_id}
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final ListSessionsPagedResponse listSessions(String parent) {
+ ListSessionsRequest request = ListSessionsRequest.newBuilder().setParent(parent).build();
+ return listSessions(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists session resources in an environment.
+ *
+ * {@code
+ * try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
+ * ListSessionsRequest request =
+ * ListSessionsRequest.newBuilder()
+ * .setParent(
+ * EnvironmentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ENVIRONMENT]")
+ * .toString())
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
+ * for (Session element : dataplexServiceClient.listSessions(request).iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ *
+ * @param 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
+ */
+ public final ListSessionsPagedResponse listSessions(ListSessionsRequest request) {
+ return listSessionsPagedCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists session resources in an environment.
+ *
+ * {@code
+ * try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
+ * ListSessionsRequest request =
+ * ListSessionsRequest.newBuilder()
+ * .setParent(
+ * EnvironmentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ENVIRONMENT]")
+ * .toString())
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
+ * ApiFuture
+ */
+ public final UnaryCallable{@code
+ * try (DataplexServiceClient dataplexServiceClient = DataplexServiceClient.create()) {
+ * ListSessionsRequest request =
+ * ListSessionsRequest.newBuilder()
+ * .setParent(
+ * EnvironmentName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ENVIRONMENT]")
+ * .toString())
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
+ * while (true) {
+ * ListSessionsResponse response = dataplexServiceClient.listSessionsCallable().call(request);
+ * for (Session element : response.getResponsesList()) {
+ * // doThingsWith(element);
+ * }
+ * String nextPageToken = response.getNextPageToken();
+ * if (!Strings.isNullOrEmpty(nextPageToken)) {
+ * request = request.toBuilder().setPageToken(nextPageToken).build();
+ * } else {
+ * break;
+ * }
+ * }
+ * }
+ * }
+ */
+ public final UnaryCallable{@code
* try (MetadataServiceClient metadataServiceClient = MetadataServiceClient.create()) {
- * EntityName name = EntityName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]", "[ENTITY]");
- * Entity response = metadataServiceClient.getEntity(name);
+ * ZoneName parent = ZoneName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]");
+ * Entity entity = Entity.newBuilder().build();
+ * Entity response = metadataServiceClient.createEntity(parent, entity);
* }
* }
*
@@ -150,6 +152,252 @@ public MetadataServiceStub getStub() {
return stub;
}
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Create a metadata entity.
+ *
+ * {@code
+ * try (MetadataServiceClient metadataServiceClient = MetadataServiceClient.create()) {
+ * ZoneName parent = ZoneName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]");
+ * Entity entity = Entity.newBuilder().build();
+ * Entity response = metadataServiceClient.createEntity(parent, entity);
+ * }
+ * }
+ *
+ * @param parent Required. The resource name of the parent zone:
+ * `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/zones/{zone_id}`.
+ * @param entity Required. Entity resource.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final Entity createEntity(ZoneName parent, Entity entity) {
+ CreateEntityRequest request =
+ CreateEntityRequest.newBuilder()
+ .setParent(parent == null ? null : parent.toString())
+ .setEntity(entity)
+ .build();
+ return createEntity(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Create a metadata entity.
+ *
+ * {@code
+ * try (MetadataServiceClient metadataServiceClient = MetadataServiceClient.create()) {
+ * String parent = ZoneName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]").toString();
+ * Entity entity = Entity.newBuilder().build();
+ * Entity response = metadataServiceClient.createEntity(parent, entity);
+ * }
+ * }
+ *
+ * @param parent Required. The resource name of the parent zone:
+ * `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/zones/{zone_id}`.
+ * @param entity Required. Entity resource.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final Entity createEntity(String parent, Entity entity) {
+ CreateEntityRequest request =
+ CreateEntityRequest.newBuilder().setParent(parent).setEntity(entity).build();
+ return createEntity(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Create a metadata entity.
+ *
+ * {@code
+ * try (MetadataServiceClient metadataServiceClient = MetadataServiceClient.create()) {
+ * CreateEntityRequest request =
+ * CreateEntityRequest.newBuilder()
+ * .setParent(ZoneName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]").toString())
+ * .setEntity(Entity.newBuilder().build())
+ * .setValidateOnly(true)
+ * .build();
+ * Entity response = metadataServiceClient.createEntity(request);
+ * }
+ * }
+ *
+ * @param 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
+ */
+ public final Entity createEntity(CreateEntityRequest request) {
+ return createEntityCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Create a metadata entity.
+ *
+ * {@code
+ * try (MetadataServiceClient metadataServiceClient = MetadataServiceClient.create()) {
+ * CreateEntityRequest request =
+ * CreateEntityRequest.newBuilder()
+ * .setParent(ZoneName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]").toString())
+ * .setEntity(Entity.newBuilder().build())
+ * .setValidateOnly(true)
+ * .build();
+ * ApiFuture
+ */
+ public final UnaryCallable{@code
+ * try (MetadataServiceClient metadataServiceClient = MetadataServiceClient.create()) {
+ * UpdateEntityRequest request =
+ * UpdateEntityRequest.newBuilder()
+ * .setEntity(Entity.newBuilder().build())
+ * .setValidateOnly(true)
+ * .build();
+ * Entity response = metadataServiceClient.updateEntity(request);
+ * }
+ * }
+ *
+ * @param 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
+ */
+ public final Entity updateEntity(UpdateEntityRequest request) {
+ return updateEntityCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Update a metadata entity. Only supports full resource update.
+ *
+ * {@code
+ * try (MetadataServiceClient metadataServiceClient = MetadataServiceClient.create()) {
+ * UpdateEntityRequest request =
+ * UpdateEntityRequest.newBuilder()
+ * .setEntity(Entity.newBuilder().build())
+ * .setValidateOnly(true)
+ * .build();
+ * ApiFuture
+ */
+ public final UnaryCallable{@code
+ * try (MetadataServiceClient metadataServiceClient = MetadataServiceClient.create()) {
+ * EntityName name = EntityName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]", "[ENTITY]");
+ * metadataServiceClient.deleteEntity(name);
+ * }
+ * }
+ *
+ * @param name Required. The resource name of the entity:
+ * `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/zones/{zone_id}/entities/{entity_id}`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final void deleteEntity(EntityName name) {
+ DeleteEntityRequest request =
+ DeleteEntityRequest.newBuilder().setName(name == null ? null : name.toString()).build();
+ deleteEntity(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Delete a metadata entity.
+ *
+ * {@code
+ * try (MetadataServiceClient metadataServiceClient = MetadataServiceClient.create()) {
+ * String name =
+ * EntityName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]", "[ENTITY]").toString();
+ * metadataServiceClient.deleteEntity(name);
+ * }
+ * }
+ *
+ * @param name Required. The resource name of the entity:
+ * `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/zones/{zone_id}/entities/{entity_id}`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final void deleteEntity(String name) {
+ DeleteEntityRequest request = DeleteEntityRequest.newBuilder().setName(name).build();
+ deleteEntity(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Delete a metadata entity.
+ *
+ * {@code
+ * try (MetadataServiceClient metadataServiceClient = MetadataServiceClient.create()) {
+ * DeleteEntityRequest request =
+ * DeleteEntityRequest.newBuilder()
+ * .setName(
+ * EntityName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]", "[ENTITY]")
+ * .toString())
+ * .setEtag("etag3123477")
+ * .build();
+ * metadataServiceClient.deleteEntity(request);
+ * }
+ * }
+ *
+ * @param 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
+ */
+ public final void deleteEntity(DeleteEntityRequest request) {
+ deleteEntityCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Delete a metadata entity.
+ *
+ * {@code
+ * try (MetadataServiceClient metadataServiceClient = MetadataServiceClient.create()) {
+ * DeleteEntityRequest request =
+ * DeleteEntityRequest.newBuilder()
+ * .setName(
+ * EntityName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]", "[ENTITY]")
+ * .toString())
+ * .setEtag("etag3123477")
+ * .build();
+ * ApiFuture
+ */
+ public final UnaryCallable{@code
+ * try (MetadataServiceClient metadataServiceClient = MetadataServiceClient.create()) {
+ * EntityName parent = EntityName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]", "[ENTITY]");
+ * Partition partition = Partition.newBuilder().build();
+ * Partition response = metadataServiceClient.createPartition(parent, partition);
+ * }
+ * }
+ *
+ * @param parent Required. The resource name of the parent zone:
+ * `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/zones/{zone_id}/entities/{entity_id}`.
+ * @param partition Required. Partition resource.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final Partition createPartition(EntityName parent, Partition partition) {
+ CreatePartitionRequest request =
+ CreatePartitionRequest.newBuilder()
+ .setParent(parent == null ? null : parent.toString())
+ .setPartition(partition)
+ .build();
+ return createPartition(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Create a metadata partition.
+ *
+ * {@code
+ * try (MetadataServiceClient metadataServiceClient = MetadataServiceClient.create()) {
+ * String parent =
+ * EntityName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]", "[ENTITY]").toString();
+ * Partition partition = Partition.newBuilder().build();
+ * Partition response = metadataServiceClient.createPartition(parent, partition);
+ * }
+ * }
+ *
+ * @param parent Required. The resource name of the parent zone:
+ * `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/zones/{zone_id}/entities/{entity_id}`.
+ * @param partition Required. Partition resource.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final Partition createPartition(String parent, Partition partition) {
+ CreatePartitionRequest request =
+ CreatePartitionRequest.newBuilder().setParent(parent).setPartition(partition).build();
+ return createPartition(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Create a metadata partition.
+ *
+ * {@code
+ * try (MetadataServiceClient metadataServiceClient = MetadataServiceClient.create()) {
+ * CreatePartitionRequest request =
+ * CreatePartitionRequest.newBuilder()
+ * .setParent(
+ * EntityName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]", "[ENTITY]")
+ * .toString())
+ * .setPartition(Partition.newBuilder().build())
+ * .setValidateOnly(true)
+ * .build();
+ * Partition response = metadataServiceClient.createPartition(request);
+ * }
+ * }
+ *
+ * @param 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
+ */
+ public final Partition createPartition(CreatePartitionRequest request) {
+ return createPartitionCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Create a metadata partition.
+ *
+ * {@code
+ * try (MetadataServiceClient metadataServiceClient = MetadataServiceClient.create()) {
+ * CreatePartitionRequest request =
+ * CreatePartitionRequest.newBuilder()
+ * .setParent(
+ * EntityName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]", "[ENTITY]")
+ * .toString())
+ * .setPartition(Partition.newBuilder().build())
+ * .setValidateOnly(true)
+ * .build();
+ * ApiFuture
+ */
+ public final UnaryCallable{@code
+ * try (MetadataServiceClient metadataServiceClient = MetadataServiceClient.create()) {
+ * PartitionName name =
+ * PartitionName.of(
+ * "[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]", "[ENTITY]", "[PARTITION]");
+ * metadataServiceClient.deletePartition(name);
+ * }
+ * }
+ *
+ * @param name Required. The resource name of the partition. format:
+ * `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/zones/{zone_id}/entities/{entity_id}/partitions/{partition_value_path}`.
+ * The {partition_value_path} segment consists of an ordered sequence of partition values
+ * separated by "/". All values must be provided.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final void deletePartition(PartitionName name) {
+ DeletePartitionRequest request =
+ DeletePartitionRequest.newBuilder().setName(name == null ? null : name.toString()).build();
+ deletePartition(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Delete a metadata partition.
+ *
+ * {@code
+ * try (MetadataServiceClient metadataServiceClient = MetadataServiceClient.create()) {
+ * String name =
+ * PartitionName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]", "[ENTITY]", "[PARTITION]")
+ * .toString();
+ * metadataServiceClient.deletePartition(name);
+ * }
+ * }
+ *
+ * @param name Required. The resource name of the partition. format:
+ * `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/zones/{zone_id}/entities/{entity_id}/partitions/{partition_value_path}`.
+ * The {partition_value_path} segment consists of an ordered sequence of partition values
+ * separated by "/". All values must be provided.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final void deletePartition(String name) {
+ DeletePartitionRequest request = DeletePartitionRequest.newBuilder().setName(name).build();
+ deletePartition(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Delete a metadata partition.
+ *
+ * {@code
+ * try (MetadataServiceClient metadataServiceClient = MetadataServiceClient.create()) {
+ * DeletePartitionRequest request =
+ * DeletePartitionRequest.newBuilder()
+ * .setName(
+ * PartitionName.of(
+ * "[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]", "[ENTITY]", "[PARTITION]")
+ * .toString())
+ * .setEtag("etag3123477")
+ * .build();
+ * metadataServiceClient.deletePartition(request);
+ * }
+ * }
+ *
+ * @param 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
+ */
+ public final void deletePartition(DeletePartitionRequest request) {
+ deletePartitionCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Delete a metadata partition.
+ *
+ * {@code
+ * try (MetadataServiceClient metadataServiceClient = MetadataServiceClient.create()) {
+ * DeletePartitionRequest request =
+ * DeletePartitionRequest.newBuilder()
+ * .setName(
+ * PartitionName.of(
+ * "[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]", "[ENTITY]", "[PARTITION]")
+ * .toString())
+ * .setEtag("etag3123477")
+ * .build();
+ * ApiFuture
+ */
+ public final UnaryCallable{@code
* MetadataServiceSettings.Builder metadataServiceSettingsBuilder =
* MetadataServiceSettings.newBuilder();
* metadataServiceSettingsBuilder
- * .getEntitySettings()
+ * .createEntitySettings()
* .setRetrySettings(
* metadataServiceSettingsBuilder
- * .getEntitySettings()
+ * .createEntitySettings()
* .getRetrySettings()
* .toBuilder()
* .setTotalTimeout(Duration.ofSeconds(30))
@@ -70,6 +71,21 @@
@Generated("by gapic-generator-java")
public class MetadataServiceSettings extends ClientSettings{@code
+ * try (ContentServiceClient contentServiceClient = ContentServiceClient.create()) {
+ * LakeName parent = LakeName.of("[PROJECT]", "[LOCATION]", "[LAKE]");
+ * Content content = Content.newBuilder().build();
+ * Content response = contentServiceClient.createContent(parent, content);
+ * }
+ * }
+ *
* {@code
* try (MetadataServiceClient metadataServiceClient = MetadataServiceClient.create()) {
- * EntityName name = EntityName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]", "[ENTITY]");
- * Entity response = metadataServiceClient.getEntity(name);
+ * ZoneName parent = ZoneName.of("[PROJECT]", "[LOCATION]", "[LAKE]", "[ZONE]");
+ * Entity entity = Entity.newBuilder().build();
+ * Entity response = metadataServiceClient.createEntity(parent, entity);
* }
* }
*
diff --git a/google-cloud-dataplex/src/main/java/com/google/cloud/dataplex/v1/stub/ContentServiceStub.java b/google-cloud-dataplex/src/main/java/com/google/cloud/dataplex/v1/stub/ContentServiceStub.java
new file mode 100644
index 0000000..459e643
--- /dev/null
+++ b/google-cloud-dataplex/src/main/java/com/google/cloud/dataplex/v1/stub/ContentServiceStub.java
@@ -0,0 +1,68 @@
+/*
+ * Copyright 2021 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.google.cloud.dataplex.v1.stub;
+
+import static com.google.cloud.dataplex.v1.ContentServiceClient.ListContentPagedResponse;
+
+import com.google.api.gax.core.BackgroundResource;
+import com.google.api.gax.rpc.UnaryCallable;
+import com.google.cloud.dataplex.v1.Content;
+import com.google.cloud.dataplex.v1.CreateContentRequest;
+import com.google.cloud.dataplex.v1.DeleteContentRequest;
+import com.google.cloud.dataplex.v1.GetContentRequest;
+import com.google.cloud.dataplex.v1.ListContentRequest;
+import com.google.cloud.dataplex.v1.ListContentResponse;
+import com.google.cloud.dataplex.v1.UpdateContentRequest;
+import com.google.protobuf.Empty;
+import javax.annotation.Generated;
+
+// AUTO-GENERATED DOCUMENTATION AND CLASS.
+/**
+ * Base stub class for the ContentService service API.
+ *
+ *
+ *
+ *
+ * {@code
+ * ContentServiceStubSettings.Builder contentServiceSettingsBuilder =
+ * ContentServiceStubSettings.newBuilder();
+ * contentServiceSettingsBuilder
+ * .createContentSettings()
+ * .setRetrySettings(
+ * contentServiceSettingsBuilder
+ * .createContentSettings()
+ * .getRetrySettings()
+ * .toBuilder()
+ * .setTotalTimeout(Duration.ofSeconds(30))
+ * .build());
+ * ContentServiceStubSettings contentServiceSettings = contentServiceSettingsBuilder.build();
+ * }
+ */
+@Generated("by gapic-generator-java")
+public class ContentServiceStubSettings extends StubSettings