org.apache.samza.job

Class CommandBuilder

java.lang.Object

org.apache.samza.job.CommandBuilder

public abstract class CommandBuilder
extends java.lang.Object

CommandBuilders are used to customize the command necessary to launch a Samza Job for a particular framework, such as YARN or the LocalJobRunner.

Field Summary

Fields

Modifier and Type	Field and Description
protected Config	config
protected int	id
protected java.net.URL	url

Constructor Summary

Constructors

Constructor and Description
CommandBuilder()

Method Summary

Modifier and Type	Method and Description
abstract java.lang.String	buildCommand()
abstract java.util.Map<java.lang.String,java.lang.String>	buildEnvironment()
CommandBuilder	setConfig(Config config)
CommandBuilder	setId(int id)
CommandBuilder	setUrl(java.net.URL url)

Methods inherited from class java.lang.Object

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

Field Detail

config

protected Config config

id

protected int id

url

protected java.net.URL url

Constructor Detail

CommandBuilder

public CommandBuilder()

Method Detail

setConfig

public CommandBuilder setConfig(Config config)

Parameters:

config - The config object to use when constructing the command and environment.

Returns:

self to support a builder style of use.

setUrl

public CommandBuilder setUrl(java.net.URL url)

Parameters:

url - The URL location of the job coordinator's HTTP server, which serves all configuration, task/SSP assignments, etc.

Returns:

self to support a builder style of use.

setId

public CommandBuilder setId(int id)

Parameters:

id - associated with a specific instantiation of a SamzaContainer.

Returns:

self to support a builder style of use.

buildCommand

public abstract java.lang.String buildCommand()

buildEnvironment

public abstract java.util.Map<java.lang.String,java.lang.String> buildEnvironment()