@PublicAPI public interface TaskId extends Comparable<TaskId>, Serializable
Modifier and Type | Field and Description |
---|---|
static String |
ITERATION_SEPARATOR
string separator in the task name for indicating the iteration index
|
static String |
REPLICATION_SEPARATOR
string separator in the task name for indicating the replication index
|
Modifier and Type | Method and Description |
---|---|
int |
getIterationIndex()
When Control Flow actions are performed on Tasks, some tasks are replicated.
|
JobId |
getJobId()
Returns the job identifier associated with this task.
|
String |
getReadableName()
Return the human readable name associated with this id.
|
int |
getReplicationIndex()
When Control Flow actions are performed on Tasks, some tasks are replicated.
|
String |
getTag()
Return the tag of the task.
|
long |
longValue()
Returns a long representation that is unique for the job
it is related to.
|
String |
toString()
Returns a String representation that is unique for
the scheduler instance it was built for.
|
String |
value()
Returns a String representation that is unique for the job
it is related to.
|
compareTo
static final String REPLICATION_SEPARATOR
static final String ITERATION_SEPARATOR
JobId getJobId()
String getReadableName()
String getTag()
String value()
toString()
for a String
representation unique for the scheduler instance it was built for.long longValue()
int getIterationIndex()
FlowActionType.IF
action
is differentiated from the original by an incremented Iteration Index.
This index is reflected in the readable name of the Task's id (getReadableName()
),
this methods safely extracts it and returns it as an int.>= 0
)int getReplicationIndex()
FlowActionType.REPLICATE
action
is differentiated from the original by an incremented Replication Index.
This index is reflected in the readable name of the Task's id (getReadableName()
),
this methods safely extracts it and returns it as an int.>= 0
)