private Put makePutFromCsvRecord()

in java/dataflow-connector-examples/src/main/java/com/google/cloud/bigtable/dataflow/example/CsvImport.java [98:112]

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

    private Put makePutFromCsvRecord(CSVRecord record) {
      Put rowPut = new Put(record.get(rowKeyColumnName).getBytes(StandardCharsets.UTF_8));
      long timestamp = System.currentTimeMillis();

      record.toMap().forEach((csvHeader, value) -> {
        if (csvHeader.equals(rowKeyColumnName)) {
          return;
        }

        rowPut.addColumn(bigTableFamilyNameBytes, csvHeader.getBytes(StandardCharsets.UTF_8), timestamp, value.getBytes(StandardCharsets.UTF_8));

      });

      return rowPut;
    }