org.apache.samza.runtime

Class ApplicationRunners

java.lang.Object

org.apache.samza.runtime.ApplicationRunners

public class ApplicationRunners
extends java.lang.Object

Creates ApplicationRunner instances based on configuration and user-implemented SamzaApplication

This class is usually used in main() function to create an instance of ApplicationRunner, as in the example below:

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

Method Summary

Modifier and Type	Method and Description
static ApplicationRunner	getApplicationRunner(SamzaApplication userApp, Config config) Get the ApplicationRunner that runs the userApp

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getApplicationRunner

public static final ApplicationRunner getApplicationRunner(SamzaApplication userApp,
                                                           Config config)

Get the ApplicationRunner that runs the userApp

Parameters:

userApp - the user application object

config - the configuration for this application

Returns:

the ApplicationRunner object that will run the userApp