List<String> getIntermediateStreamIds() {
    return intermediateStreamIds;
  }
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