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