in src/main/java/com/google/cloud/solutions/autotokenize/common/TokenizeColumnNameUpdater.java [63:82]
public FlatRecord update() {
ImmutableMap<String, Value> updatedColumnNameWithValues =
genericRecord.getValuesMap().entrySet().stream()
.map(
entry -> {
if (isTokenizeColumn(entry.getKey())) {
return ImmutablePair.of(
encryptedColumnName(entry.getKey()), entry.getValue());
}
return ImmutablePair.of(entry.getKey(), entry.getValue());
})
.collect(toImmutableMap(ImmutablePair::getLeft, ImmutablePair::getRight));
return genericRecord.toBuilder()
.clearValues()
.putAllValues(updatedColumnNameWithValues)
.build();
}