@Internal @VisibleForTesting public class OperatorStateHandles extends Object
Constructor and Description |
---|
OperatorStateHandles(int operatorChainIndex,
StreamStateHandle legacyOperatorState,
Collection<KeyedStateHandle> managedKeyedState,
Collection<KeyedStateHandle> rawKeyedState,
Collection<OperatorStateHandle> managedOperatorState,
Collection<OperatorStateHandle> rawOperatorState) |
OperatorStateHandles(TaskStateHandles taskStateHandles,
int operatorChainIndex) |
Modifier and Type | Method and Description |
---|---|
StreamStateHandle |
getLegacyOperatorState() |
Collection<KeyedStateHandle> |
getManagedKeyedState() |
Collection<OperatorStateHandle> |
getManagedOperatorState() |
int |
getOperatorChainIndex() |
Collection<KeyedStateHandle> |
getRawKeyedState() |
Collection<OperatorStateHandle> |
getRawOperatorState() |
public OperatorStateHandles(int operatorChainIndex, StreamStateHandle legacyOperatorState, Collection<KeyedStateHandle> managedKeyedState, Collection<KeyedStateHandle> rawKeyedState, Collection<OperatorStateHandle> managedOperatorState, Collection<OperatorStateHandle> rawOperatorState)
public OperatorStateHandles(TaskStateHandles taskStateHandles, int operatorChainIndex)
public StreamStateHandle getLegacyOperatorState()
public Collection<KeyedStateHandle> getManagedKeyedState()
public Collection<KeyedStateHandle> getRawKeyedState()
public Collection<OperatorStateHandle> getManagedOperatorState()
public Collection<OperatorStateHandle> getRawOperatorState()
public int getOperatorChainIndex()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.