protected PCollection makeEncryptingSteps()

in src/main/java/com/google/cloud/solutions/autotokenize/pipeline/EncryptionPipeline.java [256:272]

• 16 lines of code
• 2 McCabe index (conditional complexity)

    protected PCollection<FlatRecord> makeEncryptingSteps() {
      var flatRecordsTag = new TupleTag<FlatRecord>();

      return pipeline
          .apply(
              "Read" + SourceNames.forType(options.getSourceType()).asCamelCase(),
              TransformingReader.forSourceType(options.getSourceType())
                  .from(options.getInputPattern())
                  .withJdbcConfiguration(
                      JdbcConfigurationExtractor.using(options).jdbcConfiguration())
                  .withSecretsClient(secretsClient)
                  .withRecordsTag(flatRecordsTag)
                  .withCsvHeaders(options.getCsvHeaders())
                  .withCsvFirstRowHeader(options.getCsvFirstRowHeader()))
          .get(flatRecordsTag)
          .apply((dlpEncryptConfig != null) ? dlpDeidentify() : tinkEncryption());
    }