public class TaskStateHandles extends Object implements Serializable
Modifier and Type | Field and Description |
---|---|
static TaskStateHandles |
EMPTY |
Constructor and Description |
---|
TaskStateHandles() |
TaskStateHandles(ChainedStateHandle<StreamStateHandle> legacyOperatorState,
List<Collection<OperatorStateHandle>> managedOperatorState,
List<Collection<OperatorStateHandle>> rawOperatorState,
Collection<KeyedStateHandle> managedKeyedState,
Collection<KeyedStateHandle> rawKeyedState) |
TaskStateHandles(SubtaskState checkpointStateHandles) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
ChainedStateHandle<StreamStateHandle> |
getLegacyOperatorState()
Deprecated.
Non-repartitionable operator state that has been deprecated.
Can be removed when we remove the APIs for non-repartitionable operator state.
|
Collection<KeyedStateHandle> |
getManagedKeyedState() |
List<Collection<OperatorStateHandle>> |
getManagedOperatorState() |
Collection<KeyedStateHandle> |
getRawKeyedState() |
List<Collection<OperatorStateHandle>> |
getRawOperatorState() |
int |
hashCode() |
public static final TaskStateHandles EMPTY
public TaskStateHandles()
public TaskStateHandles(SubtaskState checkpointStateHandles)
public TaskStateHandles(ChainedStateHandle<StreamStateHandle> legacyOperatorState, List<Collection<OperatorStateHandle>> managedOperatorState, List<Collection<OperatorStateHandle>> rawOperatorState, Collection<KeyedStateHandle> managedKeyedState, Collection<KeyedStateHandle> rawKeyedState)
@Deprecated public ChainedStateHandle<StreamStateHandle> getLegacyOperatorState()
public Collection<KeyedStateHandle> getManagedKeyedState()
public Collection<KeyedStateHandle> getRawKeyedState()
public List<Collection<OperatorStateHandle>> getRawOperatorState()
public List<Collection<OperatorStateHandle>> getManagedOperatorState()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.