public static void main(String[] args) throws Exception {
    CommandLine cmdLine = new CommandLine();
    Config config = cmdLine.loadConfig(cmdLine.parser().parse(args));
    ApplicationRunner runner = ApplicationRunners.getApplicationRunner(new OrderShipmentJoinExample(), config);
    runner.run();
    runner.waitForFinish();
  }
Simple 2-way stream-to-stream join example
samza-test/src/main/java/org/apache/samza/example/OrderShipmentJoinExample.java