public void reduce()

in src/main/java/org/apache/accumulo/testing/continuous/ContinuousVerify.java [111:139]

• 23 lines of code
• 7 McCabe index (conditional complexity)

    public void reduce(LongWritable key, Iterable<VLongWritable> values, Context context)
        throws IOException, InterruptedException {

      int defCount = 0;

      refs.clear();
      for (VLongWritable type : values) {
        if (type.get() == -1) {
          defCount++;
        } else {
          refs.add(type.get());
        }
      }

      if (defCount == 0 && refs.size() > 0) {
        List<String> rowList = refs.stream().map(ContinuousIngest::genRow)
            .map(row -> new String(row, UTF_8)).collect(Collectors.toList());
        String rows = String.join(",", rowList);

        context.write(new Text(ContinuousIngest.genRow(key.get())), new Text(rows));
        context.getCounter(Counts.UNDEFINED).increment(1L);

      } else if (defCount > 0 && refs.size() == 0) {
        context.getCounter(Counts.UNREFERENCED).increment(1L);
      } else {
        context.getCounter(Counts.REFERENCED).increment(1L);
      }

    }