public class TaskState extends Object implements Serializable
JobVertex
.
This class basically groups all tasks and key groups belonging to the same job vertex together.Constructor and Description |
---|
TaskState(JobVertexID jobVertexID,
int parallelism) |
Modifier and Type | Method and Description |
---|---|
void |
discard(ClassLoader classLoader) |
boolean |
equals(Object obj) |
JobVertexID |
getJobVertexID() |
KeyGroupState |
getKvState(int keyGroupId) |
int |
getNumberCollectedKvStates() |
int |
getNumberCollectedStates() |
int |
getParallelism() |
SubtaskState |
getState(int subtaskIndex) |
Collection<SubtaskState> |
getStates() |
long |
getStateSize() |
Map<Integer,SerializedValue<StateHandle<?>>> |
getUnwrappedKvStates(Set<Integer> keyGroupPartition)
Retrieve the set of key-value state key groups specified by the given key group partition set.
|
int |
hashCode() |
void |
putKvState(int keyGroupId,
KeyGroupState keyGroupState) |
void |
putState(int subtaskIndex,
SubtaskState subtaskState) |
String |
toString() |
public TaskState(JobVertexID jobVertexID, int parallelism)
public JobVertexID getJobVertexID()
public void putState(int subtaskIndex, SubtaskState subtaskState)
public SubtaskState getState(int subtaskIndex)
public Collection<SubtaskState> getStates()
public long getStateSize()
public int getNumberCollectedStates()
public int getParallelism()
public void putKvState(int keyGroupId, KeyGroupState keyGroupState)
public KeyGroupState getKvState(int keyGroupId)
public Map<Integer,SerializedValue<StateHandle<?>>> getUnwrappedKvStates(Set<Integer> keyGroupPartition)
keyGroupPartition
- Set of key group indicespublic int getNumberCollectedKvStates()
public void discard(ClassLoader classLoader) throws Exception
Exception
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.