public void processElement()

in java/dataflow-connector-examples/src/main/java/com/google/cloud/bigtable/dataflow/example/BigQueryBigtableTransfer.java [52:64]

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

    public void processElement(DoFn<TableRow, Mutation>.ProcessContext c) throws Exception {

      TableRow row = c.element();

      //Use UUID for each HBase item's row key
      Put p = new Put(java.util.UUID.randomUUID().toString().getBytes());

      for (Map.Entry<String, Object> field : row.entrySet()) {
        p.addColumn(FAMILY, field.getKey().getBytes(), ((String) field.getValue()).getBytes());
      }
      c.output(p);

    }