@Deprecated public class TaskState extends Object implements Serializable
Constructor and Description |
---|
TaskState(JobVertexID jobVertexID,
int parallelism)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object obj)
Deprecated.
|
JobVertexID |
getJobVertexID()
Deprecated.
|
KeyGroupState |
getKvState(int keyGroupId)
Deprecated.
|
int |
getNumberCollectedKvStates()
Deprecated.
|
int |
getNumberCollectedStates()
Deprecated.
|
int |
getParallelism()
Deprecated.
|
SubtaskState |
getState(int subtaskIndex)
Deprecated.
|
Collection<SubtaskState> |
getStates()
Deprecated.
|
long |
getStateSize()
Deprecated.
|
Map<Integer,SubtaskState> |
getSubtaskStatesById()
Deprecated.
|
Map<Integer,SerializedValue<StateHandle<?>>> |
getUnwrappedKvStates(Set<Integer> keyGroupPartition)
Deprecated.
Retrieve the set of key-value state key groups specified by the given key group partition set.
|
int |
hashCode()
Deprecated.
|
void |
putKvState(int keyGroupId,
KeyGroupState keyGroupState)
Deprecated.
|
void |
putState(int subtaskIndex,
SubtaskState subtaskState)
Deprecated.
|
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 Map<Integer,SubtaskState> getSubtaskStatesById()
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()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.