public void processElement()

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

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

    public void processElement(@Element String csvRowString, OutputReceiver<Mutation> outputReceiver) throws IOException {
      try {
        outputReceiver.output(makePutFromCsvRecord(CSVParser.parse(csvRowString, makeCsvFormatWithHeaders()).getRecords().get(0)));
      } catch (Exception e) {
        LOG.error("Failed to process input {}", csvRowString, e);
        throw e;
      }
    }