@Test public void testGroupWriter() { List<Group> result = new ArrayList<Group>(); GroupRecordConsumer groupConsumer = new GroupRecordConsumer(new SimpleGroupFactory(schema)); GroupWriter groupWriter = new GroupWriter(new RecordConsumerLoggingWrapper(groupConsumer), schema); groupWriter.write(r1); result.add(groupConsumer.getCurrentRecord()); groupWriter.write(r2); result.add(groupConsumer.getCurrentRecord()); assertEquals("deserialization does not display the expected result", result.get(0).toString(), r1.toString()); assertEquals("deserialization does not display the expected result", result.get(1).toString(), r2.toString()); }
@Override public String toString() { return this.getClass().getSimpleName()+" "+type.getName() +" r:"+repetitionLevel +" d:"+definitionLevel +" "+Arrays.toString(fieldPath); }
ColumnIO { @Override public String toString() { return this.getClass().getSimpleName()+" "+type.getName() +" r:"+repetitionLevel +" d:"+definitionLevel +" "+Arrays.toString(fieldPath); } }
ColumnIO { @Override public String toString() { return this.getClass().getSimpleName()+" "+type.getName() +" r:"+repetitionLevel +" d:"+definitionLevel +" "+Arrays.toString(fieldPath); } ColumnIO(Type type, GroupColumnIO parent, int index); }
ColumnIO { @Override public String toString() { return this.getClass().getSimpleName()+" "+type.getName() +" r:"+repetitionLevel +" d:"+definitionLevel +" "+Arrays.toString(fieldPath); } ColumnIO(Type type, GroupColumnIO parent, int index); String getFieldPath(int level); int[] getIndexFieldPath(); int getIndexFieldPath(int level); int getIndex(); String getName(); Type getType(); GroupColumnIO getParent(); @Override String toString(); }
ColumnIO { @Override public String toString() { return this.getClass().getSimpleName()+" "+type.getName() +" r:"+repetitionLevel +" d:"+definitionLevel +" "+Arrays.toString(fieldPath); } ColumnIO(Type type, GroupColumnIO parent, int index); String getFieldPath(int level); int[] getIndexFieldPath(); int getIndexFieldPath(int level); int getIndex(); String getName(); Type getType(); GroupColumnIO getParent(); @Override String toString();  }