private void writeReportToDataCatalog()

in src/main/java/com/google/cloud/solutions/autotokenize/pipeline/DlpInspectionPipeline.java [193:207]


  private void writeReportToDataCatalog(PCollection<InspectionReport> inspectionReport) {
    if (isNotBlank(options.getDataCatalogInspectionTagTemplateId())) {
      inspectionReport
          .apply(
              "ExtractDataCatalogItems",
              MakeDataCatalogItems.create(options.getDataCatalogInspectionTagTemplateId()))
          .apply(
              "WriteItemsToCatalog",
              DataCatalogWriter.builder()
                  .setEntryGroupId(options.getDataCatalogEntryGroupId())
                  .setInspectionTagTemplateId(options.getDataCatalogInspectionTagTemplateId())
                  .setForceUpdate(options.getDataCatalogForcedUpdate())
                  .build());
    }
  }