  @Test
  public void testOneToMany_UnmatchedOnRightSide() {

    PTable<Integer, String> left = MemPipeline.typedTableOf(Avros.tableOf(Avros.ints(), Avros.strings()), 1, "one", 2,
        "two");
    PTable<Integer, String> right = MemPipeline.typedTableOf(Avros.tableOf(Avros.ints(), Avros.strings()), 2, "2A", 2, "2B");

    PCollection<Pair<String, String>> joined = OneToManyJoin.oneToManyJoin(left, right, new StringJoinFn(),
        Avros.pairs(Avros.strings(), Avros.strings()));

    List<Pair<String, String>> expected = ImmutableList.of(Pair.of("two", "2A,2B"));

    assertEquals(expected, Lists.newArrayList(joined.materialize()));
  }