public Tuple getNext()

in src/main/java/org/apache/accumulo/pig/AbstractAccumuloStorage.java [86:99]

• 12 lines of code
• 4 McCabe index (conditional complexity)

  public Tuple getNext() throws IOException {
    try {
      // load the next pair
      if (!reader.nextKeyValue())
        return null;
      
      Key key = (Key) reader.getCurrentKey();
      Value value = (Value) reader.getCurrentValue();
      assert key != null && value != null;
      return getTuple(key, value);
    } catch (InterruptedException e) {
      throw new IOException(e.getMessage());
    }
  }