public FlatRecord update()

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