public class

TaskCluster

extends Object
java.lang.Object
   ↳ org.apache.helix.taskexecution.TaskCluster

Summary

Constants
String DEFAULT_CLUSTER_NAME
Public Constructors
TaskCluster(String zkAddr, String clusterName)
Public Methods
void disconnect()
void setup()
void submitDag(Dag dag)
void submitDag(String dagJson)
[Expand]
Inherited Methods
From class java.lang.Object

Constants

public static final String DEFAULT_CLUSTER_NAME

Constant Value: "task-cluster"

Public Constructors

public TaskCluster (String zkAddr, String clusterName)

Throws
Exception

Public Methods

public void disconnect ()

Throws
Exception

public void setup ()

Throws
Exception

public void submitDag (Dag dag)

Throws
Exception

public void submitDag (String dagJson)

Throws
Exception