public static void main(String[] args) {
    CommandLine cmdLine = new CommandLine();
    Config config = cmdLine.loadConfig(cmdLine.parser().parse(args));
    ApplicationRunner runner = ApplicationRunners.getApplicationRunner(new TumblingWindowApp(), config);

    runner.run();
    runner.waitForFinish();
  }
A {@link StreamApplication} that demonstrates a filter followed by a tumbling window.
samza-test/src/test/java/org/apache/samza/test/operator/TumblingWindowApp.java