public class

JobConfig

extends Object
java.lang.Object
   ↳ org.apache.helix.task.JobConfig

Class Overview

Provides a typed interface to job configurations.

Summary

Nested Classes
class JobConfig.Builder A builder for JobConfig
Constants
String ASSIGNMENT_STRATEGY The assignment strategy of this job
String COMMAND The command that is to be run by participants in the case of identical tasks.
int DEFAULT_FAILURE_THRESHOLD
int DEFAULT_MAX_ATTEMPTS_PER_TASK
int DEFAULT_MAX_FORCED_REASSIGNMENTS_PER_TASK
int DEFAULT_NUM_CONCURRENT_TASKS_PER_INSTANCE
long DEFAULT_TASK_RETRY_DELAY
long DEFAULT_TIMEOUT_PER_TASK
String FAILURE_THRESHOLD The number of tasks within the job that are allowed to fail.
String JOB_COMMAND_CONFIG_MAP The command configuration to be used by the tasks.
String MAX_ATTEMPTS_PER_TASK The maximum number of times the task rebalancer may attempt to execute a task.
String MAX_FORCED_REASSIGNMENTS_PER_TASK The maximum number of times Helix will intentionally move a failing task
String NUM_CONCURRENT_TASKS_PER_INSTANCE The number of concurrent tasks that are allowed to run on an instance.
String TARGET_PARTITIONS The set of the target partition ids.
String TARGET_PARTITION_STATES The set of the target partition states.
String TARGET_RESOURCE The name of the target resource.
String TASK_CONFIGS The individual task configurations, if any
String TASK_RETRY_DELAY The amount of time in ms to wait before retrying a task
String TIMEOUT_PER_TASK The timeout for a task.
String WORKFLOW_ID The name of the workflow to which the job belongs.
Public Methods
String getCommand()
int getFailureThreshold()
Map<StringString> getJobCommandConfigMap()
int getMaxAttemptsPerTask()
int getMaxForcedReassignmentsPerTask()
int getNumConcurrentTasksPerInstance()
Map<StringString> getResourceConfigMap()
Set<String> getTargetPartitionStates()
List<String> getTargetPartitions()
String getTargetResource()
TaskConfig getTaskConfig(String id)
Map<StringTaskConfig> getTaskConfigMap()
long getTaskRetryDelay()
long getTimeoutPerTask()
String getWorkflow()
[Expand]
Inherited Methods
From class java.lang.Object

Constants

public static final String ASSIGNMENT_STRATEGY

The assignment strategy of this job

Constant Value: "AssignmentStrategy"

public static final String COMMAND

The command that is to be run by participants in the case of identical tasks.

Constant Value: "Command"

public static final int DEFAULT_FAILURE_THRESHOLD

Constant Value: 0 (0x00000000)

public static final int DEFAULT_MAX_ATTEMPTS_PER_TASK

Constant Value: 10 (0x0000000a)

public static final int DEFAULT_MAX_FORCED_REASSIGNMENTS_PER_TASK

Constant Value: 0 (0x00000000)

public static final int DEFAULT_NUM_CONCURRENT_TASKS_PER_INSTANCE

Constant Value: 1 (0x00000001)

public static final long DEFAULT_TASK_RETRY_DELAY

Constant Value: -1 (0xffffffffffffffff)

public static final long DEFAULT_TIMEOUT_PER_TASK

Constant Value: 3600000 (0x000000000036ee80)

public static final String FAILURE_THRESHOLD

The number of tasks within the job that are allowed to fail.

Constant Value: "FailureThreshold"

public static final String JOB_COMMAND_CONFIG_MAP

The command configuration to be used by the tasks.

Constant Value: "JobCommandConfig"

public static final String MAX_ATTEMPTS_PER_TASK

The maximum number of times the task rebalancer may attempt to execute a task.

Constant Value: "MaxAttemptsPerTask"

public static final String MAX_FORCED_REASSIGNMENTS_PER_TASK

The maximum number of times Helix will intentionally move a failing task

Constant Value: "MaxForcedReassignmentsPerTask"

public static final String NUM_CONCURRENT_TASKS_PER_INSTANCE

The number of concurrent tasks that are allowed to run on an instance.

Constant Value: "ConcurrentTasksPerInstance"

public static final String TARGET_PARTITIONS

The set of the target partition ids. The value must be a comma-separated list of partition ids.

Constant Value: "TargetPartitions"

public static final String TARGET_PARTITION_STATES

The set of the target partition states. The value must be a comma-separated list of partition states.

Constant Value: "TargetPartitionStates"

public static final String TARGET_RESOURCE

The name of the target resource.

Constant Value: "TargetResource"

public static final String TASK_CONFIGS

The individual task configurations, if any

Constant Value: "TaskConfigs"

public static final String TASK_RETRY_DELAY

The amount of time in ms to wait before retrying a task

Constant Value: "TaskRetryDelay"

public static final String TIMEOUT_PER_TASK

The timeout for a task.

Constant Value: "TimeoutPerPartition"

public static final String WORKFLOW_ID

The name of the workflow to which the job belongs.

Constant Value: "WorkflowID"

Public Methods

public String getCommand ()

public int getFailureThreshold ()

public Map<StringString> getJobCommandConfigMap ()

public int getMaxAttemptsPerTask ()

public int getMaxForcedReassignmentsPerTask ()

public int getNumConcurrentTasksPerInstance ()

public Map<StringString> getResourceConfigMap ()

public Set<String> getTargetPartitionStates ()

public List<String> getTargetPartitions ()

public String getTargetResource ()

public TaskConfig getTaskConfig (String id)

public Map<StringTaskConfig> getTaskConfigMap ()

public long getTaskRetryDelay ()

public long getTimeoutPerTask ()

public String getWorkflow ()