@Override
  public Integer getMessageKey(KV<Integer, TestTableData.PageView> message) {
    return message.getKey();
  }
A {@link StreamTableJoinFunction} used by unit tests in this package
samza-test/src/test/java/org/apache/samza/test/table/PageViewToProfileJoinFunction.java