public class SubtaskState extends Object implements StateObject
TaskState
.Constructor and Description |
---|
SubtaskState(ChainedStateHandle<StreamStateHandle> legacyOperatorState,
ChainedStateHandle<OperatorStateHandle> managedOperatorState,
ChainedStateHandle<OperatorStateHandle> rawOperatorState,
KeyGroupsStateHandle managedKeyedState,
KeyGroupsStateHandle rawKeyedState) |
Modifier and Type | Method and Description |
---|---|
void |
discardState()
Discards the state referred to by this handle, to free up resources in
the persistent storage.
|
boolean |
equals(Object o) |
ChainedStateHandle<StreamStateHandle> |
getLegacyOperatorState()
Deprecated.
|
KeyGroupsStateHandle |
getManagedKeyedState() |
ChainedStateHandle<OperatorStateHandle> |
getManagedOperatorState() |
KeyGroupsStateHandle |
getRawKeyedState() |
ChainedStateHandle<OperatorStateHandle> |
getRawOperatorState() |
long |
getStateSize()
Returns the size of the state in bytes.
|
int |
hashCode() |
String |
toString() |
public SubtaskState(ChainedStateHandle<StreamStateHandle> legacyOperatorState, ChainedStateHandle<OperatorStateHandle> managedOperatorState, ChainedStateHandle<OperatorStateHandle> rawOperatorState, KeyGroupsStateHandle managedKeyedState, KeyGroupsStateHandle rawKeyedState)
@Deprecated public ChainedStateHandle<StreamStateHandle> getLegacyOperatorState()
public ChainedStateHandle<OperatorStateHandle> getManagedOperatorState()
public ChainedStateHandle<OperatorStateHandle> getRawOperatorState()
public KeyGroupsStateHandle getManagedKeyedState()
public KeyGroupsStateHandle getRawKeyedState()
public long getStateSize()
StateObject
If the the size is not known, return 0
.
getStateSize
in interface StateObject
public void discardState() throws Exception
StateObject
discardState
in interface StateObject
Exception
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.