public Collection getMutations()

in src/main/java/org/apache/accumulo/pig/AccumuloWholeRowStorage.java [91:106]

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

  public Collection<Mutation> getMutations(Tuple tuple) throws ExecException, IOException {
    
    Mutation mut = new Mutation(Utils.objToText(tuple.get(0)));
    DefaultDataBag columns = (DefaultDataBag) tuple.get(1);
    for (Tuple column : columns) {
      Text cf = Utils.objToText(column.get(0));
      Text cq = Utils.objToText(column.get(1));
      Text cv = Utils.objToText(column.get(2));
      Long ts = (Long) column.get(3);
      Value val = new Value(Utils.objToBytes(column.get(4)));
      
      mut.put(cf, cq, new ColumnVisibility(cv), ts, val);
    }
    
    return Collections.singleton(mut);
  }