in src/main/java/com/google/cloud/solutions/bqremoteencryptionfn/fns/dlp/DlpFn.java [111:132]
public List<String> deidentifyUnaryRow(List<String> rows) throws Exception {
return DlpRequestBatchExecutor.<DeidentifyContentRequest, DeidentifyContentResponse>builder()
.setDlpColumnName(dlpColName)
.setRequestCellCount(requestCellCount)
.setRequestMaxBytes(requestBytes)
.setDlpClientFactory(dlpClientFactory)
.setDlpCallFnFactory(dlpClient -> dlpClient::deidentifyContent)
.setTableToDlpRequestFnFactory(
dlpClient ->
table ->
DeidentifyContentRequest.newBuilder()
.setParent(extractDlpParent(dlpConfig.deidTemplate()))
.setDeidentifyTemplateName(dlpConfig.deidTemplate())
.setInspectTemplateName(
dlpConfig.hasInspectTemplate() ? dlpConfig.inspectTemplate() : "")
.setItem(ContentItem.newBuilder().setTable(table).build())
.build())
.setDlpRequestToTableFn(deidRequest -> deidRequest.getItem().getTable())
.setDlpResponseToTableFn(deidResponse -> deidResponse.getItem().getTable())
.build()
.process(rows);
}