@Deprecated @Internal public class StreamTaskState extends Object implements Serializable, Closeable
Constructor and Description |
---|
StreamTaskState()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Deprecated.
|
StateHandle<Serializable> |
getFunctionState()
Deprecated.
|
HashMap<String,KvStateSnapshot<?,?,?,?>> |
getKvStates()
Deprecated.
|
StateHandle<?> |
getOperatorState()
Deprecated.
|
boolean |
isEmpty()
Deprecated.
Checks if this state object actually contains any state, or if all of the state
fields are null.
|
void |
setFunctionState(StateHandle<Serializable> functionState)
Deprecated.
|
void |
setKvStates(HashMap<String,KvStateSnapshot<?,?,?,?>> kvStates)
Deprecated.
|
void |
setOperatorState(StateHandle<?> operatorState)
Deprecated.
|
public StateHandle<?> getOperatorState()
public void setOperatorState(StateHandle<?> operatorState)
public StateHandle<Serializable> getFunctionState()
public void setFunctionState(StateHandle<Serializable> functionState)
public HashMap<String,KvStateSnapshot<?,?,?,?>> getKvStates()
public void setKvStates(HashMap<String,KvStateSnapshot<?,?,?,?>> kvStates)
public boolean isEmpty()
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.