in src/main/java/com/google/cloud/solutions/autotokenize/pipeline/MakeInspectionReport.java [122:140]
public void createCombinedReport(
@Element Iterable<ColumnInformation> sensitiveColumns,
@SideInput(SCHEMA_SIDE_INPUT_TAG) String avroSchemaString,
OutputReceiver<InspectionReport> outputReceiver) {
var inspectionReportBuilder =
InspectionReport.newBuilder()
.setTimestamp(Timestamps.fromMillis(clock().instant().toEpochMilli()))
.setSourceType(sourceType())
.setInputPattern(inputPattern())
.setAvroSchema(avroSchemaString)
.addAllColumnReport(sensitiveColumns);
if (jdbcConfiguration() != null) {
inspectionReportBuilder.setJdbcConfiguration(jdbcConfiguration());
}
outputReceiver.output(inspectionReportBuilder.build());
}