@Internal @VisibleForTesting public class OperatorStateHandles extends Object
Constructor and Description |
---|
OperatorStateHandles(int operatorChainIndex,
Collection<KeyedStateHandle> managedKeyedState,
Collection<KeyedStateHandle> rawKeyedState,
Collection<OperatorStateHandle> managedOperatorState,
Collection<OperatorStateHandle> rawOperatorState) |
Modifier and Type | Method and Description |
---|---|
Collection<KeyedStateHandle> |
getManagedKeyedState() |
Collection<OperatorStateHandle> |
getManagedOperatorState() |
int |
getOperatorChainIndex() |
Collection<KeyedStateHandle> |
getRawKeyedState() |
Collection<OperatorStateHandle> |
getRawOperatorState() |
public OperatorStateHandles(int operatorChainIndex, Collection<KeyedStateHandle> managedKeyedState, Collection<KeyedStateHandle> rawKeyedState, Collection<OperatorStateHandle> managedOperatorState, Collection<OperatorStateHandle> rawOperatorState)
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.