public class SubtaskState extends Object implements Serializable
TaskState
.
The state itself is kept in serialized form, since the checkpoint coordinator itself
is never looking at it anyways and only sends it back out in case of a recovery.
Furthermore, the state may involve user-defined classes that are not accessible without
the respective classloader.Constructor and Description |
---|
SubtaskState(SerializedValue<StateHandle<?>> state,
long stateSize,
long duration) |
Modifier and Type | Method and Description |
---|---|
void |
discard(ClassLoader userClassLoader) |
boolean |
equals(Object o) |
long |
getDuration() |
SerializedValue<StateHandle<?>> |
getState() |
long |
getStateSize() |
int |
hashCode() |
String |
toString() |
public SubtaskState(SerializedValue<StateHandle<?>> state, long stateSize, long duration)
public SerializedValue<StateHandle<?>> getState()
public long getStateSize()
public long getDuration()
public void discard(ClassLoader userClassLoader) throws Exception
Exception
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.