public class

WorkflowContext

extends HelixProperty
java.lang.Object
   ↳ org.apache.helix.HelixProperty
     ↳ org.apache.helix.task.WorkflowContext

Class Overview

Typed interface to the workflow context information stored by TaskRebalancer in the Helix property store

Summary

Constants
String FINISH_TIME
String JOB_STATES
String LAST_SCHEDULED_WORKFLOW
String START_TIME
int UNFINISHED
String WORKFLOW_STATE
[Expand]
Inherited Fields
From class org.apache.helix.HelixProperty
Public Constructors
WorkflowContext(ZNRecord record)
Public Methods
long getFinishTime()
TaskState getJobState(String jobResource)
String getLastScheduledSingleWorkflow()
long getStartTime()
TaskState getWorkflowState()
void setFinishTime(long t)
void setJobState(String jobResource, TaskState s)
void setLastScheduledSingleWorkflow(String wf)
void setStartTime(long t)
void setWorkflowState(TaskState s)
[Expand]
Inherited Methods
From class org.apache.helix.HelixProperty
From class java.lang.Object

Constants

public static final String FINISH_TIME

Constant Value: "FINISH_TIME"

public static final String JOB_STATES

Constant Value: "JOB_STATES"

public static final String LAST_SCHEDULED_WORKFLOW

Constant Value: "LAST_SCHEDULED_WORKFLOW"

public static final String START_TIME

Constant Value: "START_TIME"

public static final int UNFINISHED

Constant Value: -1 (0xffffffff)

public static final String WORKFLOW_STATE

Constant Value: "STATE"

Public Constructors

public WorkflowContext (ZNRecord record)

Public Methods

public long getFinishTime ()

public TaskState getJobState (String jobResource)

public String getLastScheduledSingleWorkflow ()

public long getStartTime ()

public TaskState getWorkflowState ()

public void setFinishTime (long t)

public void setJobState (String jobResource, TaskState s)

public void setLastScheduledSingleWorkflow (String wf)

public void setStartTime (long t)

public void setWorkflowState (TaskState s)