@Internal public class StreamTaskStateList extends Object implements StateHandle<StreamTaskState[]>
Constructor and Description |
---|
StreamTaskStateList(StreamTaskState[] states) |
Modifier and Type | Method and Description |
---|---|
void |
discardState()
Discards the state referred to by this handle, to free up resources in
the persistent storage.
|
StreamTaskState[] |
getState(ClassLoader userCodeClassLoader)
This retrieves and return the state represented by the handle.
|
long |
getStateSize()
Returns the size of the state in bytes.
|
boolean |
isEmpty() |
public StreamTaskStateList(StreamTaskState[] states) throws Exception
Exception
public boolean isEmpty()
public StreamTaskState[] getState(ClassLoader userCodeClassLoader)
StateHandle
getState
in interface StateHandle<StreamTaskState[]>
userCodeClassLoader
- Class loader for deserializing user code specific classespublic void discardState() throws Exception
StateHandle
discardState
in interface StateHandle<StreamTaskState[]>
Exception
public long getStateSize() throws Exception
StateHandle
If the the size is not known, return 0
.
getStateSize
in interface StateHandle<StreamTaskState[]>
Exception
- If the operation fails during size retrieval.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.