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 java.lang.String	commandPath
protected Config	config
protected java.lang.String	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	setCommandPath(java.lang.String path)
CommandBuilder	setConfig(Config config)
CommandBuilder	setId(java.lang.String 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 java.lang.String id

url

protected java.net.URL url

commandPath

protected java.lang.String commandPath

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(java.lang.String id)

Parameters:

id - associated with a specific instantiation of a SamzaContainer.

Returns:

self to support a builder style of use.

setCommandPath

public CommandBuilder setCommandPath(java.lang.String path)

Parameters:

path - Specify path to the command (in case it needs to be adjusted)

Returns:

self

buildCommand

public abstract java.lang.String buildCommand()

buildEnvironment

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