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 java.lang.String	name
protected java.util.Set<SystemStreamPartition>	systemStreamPartitions

Constructor Summary

Constructors

Constructor and Description
CommandBuilder()

Method Summary

Methods

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	setName(java.lang.String name)
CommandBuilder	setStreamPartitions(java.util.Set<SystemStreamPartition> ssp)

Methods inherited from class java.lang.Object

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

Field Detail

systemStreamPartitions

protected java.util.Set<SystemStreamPartition> systemStreamPartitions

name

protected java.lang.String name

config

protected Config config

Constructor Detail

CommandBuilder

public CommandBuilder()

Method Detail

setStreamPartitions

public CommandBuilder setStreamPartitions(java.util.Set<SystemStreamPartition> ssp)

setName

public CommandBuilder setName(java.lang.String name)

Parameters:

name - associated with a specific instantiation of a TaskRunner.

Returns:

self to support a builder style of use.

setConfig

public CommandBuilder setConfig(Config config)

buildCommand

public abstract java.lang.String buildCommand()

buildEnvironment

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