Create Java code sample for create job (GoogleCloudPlatform#3017)

https://cloud.google.com/dlp/docs/creating-job-triggers

Fixes #Create Java code sample for create job

> It's a good idea to open an issue first for discussion.

> [yes] I have followed Sample Format Guide
> [yes] pom.xml parent set to latest shared-configuration
> [yes] Appropriate changes to README are included in PR
> [nothing new] API's need to be enabled to test (tell us)
> [nothing new] Environment Variables need to be set (ask us to set them)
> [yes] Tests pass (mvn -P lint clean verify)
> (Note- Checkstyle passing is required; Spotbugs, ErrorProne, PMD, etc. ERROR's are advisory only)
> [yes] Please merge this PR for me once it is approved

Author: chloeliu123

dlp/src/main/java/dlp/snippets/JobsCreate.java

@@ -0,0 +1,118 @@
+/*
+ * Copyright 2020 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
+ *
+ * http://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 dlp.snippets;
+
+// [START dlp_create_job]
+
+import com.google.cloud.dlp.v2.DlpServiceClient;
+import com.google.privacy.dlp.v2.Action;
+import com.google.privacy.dlp.v2.CloudStorageOptions;
+import com.google.privacy.dlp.v2.CreateDlpJobRequest;
+import com.google.privacy.dlp.v2.InfoType;
+import com.google.privacy.dlp.v2.InspectConfig;
+import com.google.privacy.dlp.v2.InspectJobConfig;
+import com.google.privacy.dlp.v2.Likelihood;
+import com.google.privacy.dlp.v2.ProjectName;
+import com.google.privacy.dlp.v2.StorageConfig;
+import com.google.privacy.dlp.v2.StorageConfig.TimespanConfig;
+import java.io.IOException;
+import java.util.List;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
+
+public class JobsCreate {
+  public static void createJobs() throws IOException {
+    // TODO(developer): Replace these variables before running the sample.
+    String projectId = "your-project-id";
+    String gcsPath = "gs://" + "your-bucket-name" + "path/to/file.txt";
+    createJobs(projectId, gcsPath);
+  }
+
+  // Creates a DLP Job
+  public static void createJobs(String projectId, String gcsPath) throws IOException {
+    // Initialize client that will be used to send requests. This client only needs to be created
+    // once, and can be reused for multiple requests. After completing all of your requests, call
+    // the "close" method on the client to safely clean up any remaining background resources.
+    try (DlpServiceClient dlpServiceClient = DlpServiceClient.create()) {
+
+      // Set autoPopulateTimespan to true to scan only new content
+      boolean autoPopulateTimespan = true;
+      TimespanConfig timespanConfig =
+          TimespanConfig.newBuilder()
+              .setEnableAutoPopulationOfTimespanConfig(autoPopulateTimespan)
+              .build();
+
+      // Specify the GCS file to be inspected.
+      CloudStorageOptions cloudStorageOptions =
+          CloudStorageOptions.newBuilder()
+              .setFileSet(CloudStorageOptions.FileSet.newBuilder().setUrl(gcsPath))
+              .build();
+      StorageConfig storageConfig =
+          StorageConfig.newBuilder()
+              .setCloudStorageOptions(cloudStorageOptions)
+              .setTimespanConfig(timespanConfig)
+              .build();
+
+      // Specify the type of info the inspection will look for.
+      // See https://cloud.google.com/dlp/docs/infotypes-reference for complete list of info types
+      List<InfoType> infoTypes =
+          Stream.of("EMAIL_ADDRESS", "PERSON_NAME", "LOCATION", "PHONE_NUMBER")
+              .map(it -> InfoType.newBuilder().setName(it).build())
+              .collect(Collectors.toList());
+      // The minimum likelihood required before returning a match:
+      // See: https://cloud.google.com/dlp/docs/likelihood
+      Likelihood minLikelihood = Likelihood.UNLIKELY;
+
+      // The maximum number of findings to report (0 = server maximum)
+      InspectConfig.FindingLimits findingLimits =
+          InspectConfig.FindingLimits.newBuilder().setMaxFindingsPerItem(100).build();
+
+      InspectConfig inspectConfig =
+          InspectConfig.newBuilder()
+              .addAllInfoTypes(infoTypes)
+              .setIncludeQuote(true)
+              .setMinLikelihood(minLikelihood)
+              .setLimits(findingLimits)
+              .build();
+
+      // Specify the action that is triggered when the job completes.
+      Action.PublishSummaryToCscc publishSummaryToCscc =
+          Action.PublishSummaryToCscc.getDefaultInstance();
+      Action action = Action.newBuilder().setPublishSummaryToCscc(publishSummaryToCscc).build();
+
+      // Configure the inspection job we want the service to perform.
+      InspectJobConfig inspectJobConfig =
+          InspectJobConfig.newBuilder()
+              .setInspectConfig(inspectConfig)
+              .setStorageConfig(storageConfig)
+              .addActions(action)
+              .build();
+
+      // Construct the job creation request to be sent by the client.
+      CreateDlpJobRequest createDlpJobRequest =
+          CreateDlpJobRequest.newBuilder()
+              .setParent(ProjectName.of(projectId).toString())
+              .setInspectJob(inspectJobConfig)
+              .build();
+
+      // Send the job creation request
+      dlpServiceClient.createDlpJob(createDlpJobRequest);
+      System.out.println("Job created successfully.");
+    }
+  }
+}
+// [END dlp_create_job]

dlp/src/test/java/dlp/snippets/JobsTests.java

@@ -98,6 +98,14 @@ public void tearDown() {
     bout.reset();
   }
 
+  @Test
+  public void testCreateJobs() throws Exception {
+    // Call createJobs to create a Dlp job from project id and gcs path.
+    JobsCreate.createJobs(PROJECT_ID, GCS_PATH);
+    String output = bout.toString();
+    assertThat(output, CoreMatchers.containsString("Job created successfully."));
+  }
+
   @Test
   public void testListJobs() throws Exception {
     // Call listJobs to print out a list of jobIds