StateForTask (flink-runtime 0.9.0 API)

```
public class StateForTask
extends Object
```
Simple bean to describe the state belonging to a parallel operator. Since we hold the state across execution attempts, we identify a task by its JobVertexId and subtask index. The state itself is kept in serialized from, 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.

Constructors
Constructor and Description
`StateForTask(SerializedValue<StateHandle<?>> state, JobVertexID operatorId, int subtask)`

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`discard(ClassLoader userClassLoader)`
`boolean`	`equals(Object o)`
`JobVertexID`	`getOperatorId()`
`SerializedValue<StateHandle<?>>`	`getState()`
`int`	`getSubtask()`
`int`	`hashCode()`
`String`	`toString()`

Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait

public StateForTask(SerializedValue<StateHandle<?>> state,
                    JobVertexID operatorId,
                    int subtask)

public SerializedValue<StateHandle<?>> getState()

public void discard(ClassLoader userClassLoader)

Class StateForTask