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.Map<TaskName,java.lang.Integer>	taskNameToChangeLogPartitionMapping
protected java.util.Map<TaskName,java.util.Set<SystemStreamPartition>>	taskNameToSystemStreamPartitionsMapping

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	setName(java.lang.String name)
CommandBuilder	setTaskNameToChangeLogPartitionMapping(java.util.Map<TaskName,java.lang.Integer> mapping)
CommandBuilder	setTaskNameToSystemStreamPartitionsMapping(java.util.Map<TaskName,java.util.Set<SystemStreamPartition>> systemStreamPartitionTaskNames)

Methods inherited from class java.lang.Object

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

Field Detail

taskNameToSystemStreamPartitionsMapping

protected java.util.Map<TaskName,java.util.Set<SystemStreamPartition>> taskNameToSystemStreamPartitionsMapping

taskNameToChangeLogPartitionMapping

protected java.util.Map<TaskName,java.lang.Integer> taskNameToChangeLogPartitionMapping

name

protected java.lang.String name

config

protected Config config

Constructor Detail

CommandBuilder

public CommandBuilder()

Method Detail

setTaskNameToSystemStreamPartitionsMapping

public CommandBuilder setTaskNameToSystemStreamPartitionsMapping(java.util.Map<TaskName,java.util.Set<SystemStreamPartition>> systemStreamPartitionTaskNames)

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)

setTaskNameToChangeLogPartitionMapping

public CommandBuilder setTaskNameToChangeLogPartitionMapping(java.util.Map<TaskName,java.lang.Integer> mapping)

buildCommand

public abstract java.lang.String buildCommand()

buildEnvironment

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