@Override
  public TestTableData.EnrichedPageView apply(KV<Integer, TestTableData.PageView> m, KV<Integer, TestTableData.Profile> r) {
    return r == null ? null : new TestTableData.EnrichedPageView(m.getValue().getPageKey(), m.getKey(), r.getValue().getCompany());
  }
A {@link StreamTableJoinFunction} used by unit tests in this package
samza-test/src/test/java/org/apache/samza/test/table/PageViewToProfileJoinFunction.java