TestJoinTupleWritable.java 文件源码

private TupleWritable makeTuple(Writable[] writs) {
  Writable[] sub1 = { writs[1], writs[2] };
  Writable[] sub3 = { writs[4], writs[5] };
  Writable[] sub2 = { writs[3], new TupleWritable(sub3), writs[6] };
  Writable[] vals = { writs[0], new TupleWritable(sub1),
                      new TupleWritable(sub2), writs[7], writs[8],
                      writs[9] };
  // [v0, [v1, v2], [v3, [v4, v5], v6], v7, v8, v9]
  TupleWritable ret = new TupleWritable(vals);
  for (int i = 0; i < 6; ++i) {
    ret.setWritten(i);
  }
  ((TupleWritable)sub2[1]).setWritten(0);
  ((TupleWritable)sub2[1]).setWritten(1);
  ((TupleWritable)vals[1]).setWritten(0);
  ((TupleWritable)vals[1]).setWritten(1);
  for (int i = 0; i < 3; ++i) {
    ((TupleWritable)vals[2]).setWritten(i);
  }
  return ret;
}