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());
}
}