@Override
    public String getFirstKey(PageView pv) {
      return pv.getViewId();
    }
A {@link StreamApplication} that demonstrates a partitionBy, stream-stream join and a windowed count.
samza-test/src/test/java/org/apache/samza/test/operator/RepartitionJoinWindowApp.java