@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"));
}