Join { public Join(Schema schema) { this.schema = schema; this.builder = new GenericRecordBuilder(schema); } Join(Schema schema); GenericRecordBuilder getBuilder(); Join merge(GenericRecord record);  }
@Test public void testJoin() throws IOException { GenericRecord in1 = getIn1(); GenericRecord in2 = getIn2(); GenericRecord joined = new Join(getJoinedSchema()) .merge(in1) .merge(in2) .getBuilder() .set("charlie", "blah blah") .build(); assertEquals("yo yo", joined.get("foo")); assertEquals(5, joined.get("bar")); assertEquals("blah blah", joined.get("charlie")); }