org.apache.samza.system

Interface ExecutionEnvironment

@InterfaceStability.Unstable
public interface ExecutionEnvironment

Interface to be implemented by physical execution engine to deploy the config and jobs to run the StreamGraph

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DEFAULT_ENVIRONMENT_CLASS
static java.lang.String	ENVIRONMENT_CONFIG

Method Summary

Modifier and Type	Method and Description
static ExecutionEnvironment	fromConfig(Config config) Static method to load the non-standalone environment.
static ExecutionEnvironment	getLocalEnvironment(Config config) Static method to load the local standalone environment
void	run(StreamGraphBuilder graphBuilder, Config config) Method to be invoked to deploy and run the actual Samza jobs to execute StreamGraph

Field Detail

ENVIRONMENT_CONFIG

static final java.lang.String ENVIRONMENT_CONFIG

See Also:

Constant Field Values

DEFAULT_ENVIRONMENT_CLASS

static final java.lang.String DEFAULT_ENVIRONMENT_CLASS

See Also:

Constant Field Values

Method Detail

getLocalEnvironment

static ExecutionEnvironment getLocalEnvironment(Config config)

Static method to load the local standalone environment

Parameters:

config - configuration passed in to initialize the Samza standalone process

Returns:

the standalone ExecutionEnvironment to run the user-defined stream applications

fromConfig

static ExecutionEnvironment fromConfig(Config config)

Static method to load the non-standalone environment.

Parameters:

config - configuration passed in to initialize the Samza processes

Returns:

the configure-driven ExecutionEnvironment to run the user-defined stream applications

run

void run(StreamGraphBuilder graphBuilder,
         Config config)

Method to be invoked to deploy and run the actual Samza jobs to execute StreamGraph

Parameters:

graphBuilder - the user-defined StreamGraphBuilder object

config - the Config object for this job