public class StateInitializationContextImpl extends Object implements StateInitializationContext
StateInitializationContext
.Constructor and Description |
---|
StateInitializationContextImpl(boolean restored,
OperatorStateStore operatorStateStore,
KeyedStateStore keyedStateStore,
Collection<KeyedStateHandle> keyedStateHandles,
Collection<OperatorStateHandle> operatorStateHandles,
CloseableRegistry closableRegistry) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
CloseableRegistry |
getClosableRegistry() |
KeyedStateStore |
getKeyedStateStore()
Returns an interface that allows for registering keyed state with the backend.
|
Collection<KeyGroupsStateHandle> |
getKeyGroupsStateHandles() |
Collection<OperatorStateHandle> |
getOperatorStateHandles() |
OperatorStateStore |
getOperatorStateStore()
Returns an interface that allows for registering operator state with the backend.
|
Iterable<KeyGroupStatePartitionStreamProvider> |
getRawKeyedStateInputs()
Returns an iterable to obtain input streams for previously stored keyed state partitions that are assigned to
this operator.
|
Iterable<StatePartitionStreamProvider> |
getRawOperatorStateInputs()
Returns an iterable to obtain input streams for previously stored operator state partitions that are assigned to
this operator.
|
boolean |
isRestored()
Returns true, if state was restored from the snapshot of a previous execution.
|
public StateInitializationContextImpl(boolean restored, OperatorStateStore operatorStateStore, KeyedStateStore keyedStateStore, Collection<KeyedStateHandle> keyedStateHandles, Collection<OperatorStateHandle> operatorStateHandles, CloseableRegistry closableRegistry)
public boolean isRestored()
ManagedInitializationContext
isRestored
in interface ManagedInitializationContext
public Collection<OperatorStateHandle> getOperatorStateHandles()
public Collection<KeyGroupsStateHandle> getKeyGroupsStateHandles()
public CloseableRegistry getClosableRegistry()
public Iterable<StatePartitionStreamProvider> getRawOperatorStateInputs()
StateInitializationContext
getRawOperatorStateInputs
in interface StateInitializationContext
public Iterable<KeyGroupStatePartitionStreamProvider> getRawKeyedStateInputs()
StateInitializationContext
getRawKeyedStateInputs
in interface StateInitializationContext
public OperatorStateStore getOperatorStateStore()
ManagedInitializationContext
getOperatorStateStore
in interface ManagedInitializationContext
public KeyedStateStore getKeyedStateStore()
ManagedInitializationContext
getKeyedStateStore
in interface ManagedInitializationContext
public void close()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.