Package | Description |
---|---|
org.apache.flink.runtime.state | |
org.apache.flink.streaming.api.operators |
Modifier and Type | Class and Description |
---|---|
class |
DefaultKeyedStateStore
Default implementation of KeyedStateStore that currently forwards state registration to a
RuntimeContext . |
Modifier and Type | Method and Description |
---|---|
KeyedStateStore |
StateInitializationContextImpl.getKeyedStateStore() |
KeyedStateStore |
ManagedInitializationContext.getKeyedStateStore()
Returns an interface that allows for registering keyed state with the backend.
|
Constructor and Description |
---|
StateInitializationContextImpl(boolean restored,
OperatorStateStore operatorStateStore,
KeyedStateStore keyedStateStore,
Collection<KeyGroupsStateHandle> keyGroupsStateHandles,
Collection<OperatorStateHandle> operatorStateHandles,
CloseableRegistry closableRegistry) |
Modifier and Type | Method and Description |
---|---|
KeyedStateStore |
AbstractStreamOperator.getKeyedStateStore() |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.