protected Tuple getTuple()

in src/main/java/org/apache/accumulo/pig/AccumuloWholeRowStorage.java [59:74]

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

  protected Tuple getTuple(Key key, Value value) throws IOException {
    
    SortedMap<Key,Value> rowKVs = WholeRowIterator.decodeRow(key, value);
    List<Tuple> columns = new ArrayList<Tuple>(rowKVs.size());
    for (Entry<Key,Value> e : rowKVs.entrySet()) {
      columns.add(columnToTuple(e.getKey().getColumnFamily(), e.getKey().getColumnQualifier(), e.getKey().getColumnVisibility(), e.getKey().getTimestamp(),
          e.getValue()));
    }
    
    // and wrap it in a tuple
    Tuple tuple = TupleFactory.getInstance().newTuple(2);
    tuple.set(0, new DataByteArray(key.getRow().getBytes()));
    tuple.set(1, new DefaultDataBag(columns));
    
    return tuple;
  }