Uses of Interface
org.apache.flink.runtime.state.StateBackend.KeyedStateBackendParameters
-
-
Uses of StateBackend.KeyedStateBackendParameters in org.apache.flink.contrib.streaming.state
Methods in org.apache.flink.contrib.streaming.state with parameters of type StateBackend.KeyedStateBackendParameters Modifier and Type Method Description <K> AbstractKeyedStateBackend<K>
EmbeddedRocksDBStateBackend. createKeyedStateBackend(StateBackend.KeyedStateBackendParameters<K> parameters)
-
Uses of StateBackend.KeyedStateBackendParameters in org.apache.flink.runtime.state
Classes in org.apache.flink.runtime.state that implement StateBackend.KeyedStateBackendParameters Modifier and Type Class Description class
KeyedStateBackendParametersImpl<K>
Internal POJO implementingStateBackend.KeyedStateBackendParameters
Methods in org.apache.flink.runtime.state with parameters of type StateBackend.KeyedStateBackendParameters Modifier and Type Method Description default <K> AsyncKeyedStateBackend<K>
StateBackend. createAsyncKeyedStateBackend(StateBackend.KeyedStateBackendParameters<K> parameters)
Creates a newAsyncKeyedStateBackend
which supports to access keyed state asynchronously.abstract <K> AbstractKeyedStateBackend<K>
AbstractManagedMemoryStateBackend. createKeyedStateBackend(StateBackend.KeyedStateBackendParameters<K> parameters)
abstract <K> AbstractKeyedStateBackend<K>
AbstractStateBackend. createKeyedStateBackend(StateBackend.KeyedStateBackendParameters<K> parameters)
<K> CheckpointableKeyedStateBackend<K>
StateBackend. createKeyedStateBackend(StateBackend.KeyedStateBackendParameters<K> parameters)
Creates a newCheckpointableKeyedStateBackend
that is responsible for holding keyed state and checkpointing it.Constructors in org.apache.flink.runtime.state with parameters of type StateBackend.KeyedStateBackendParameters Constructor Description KeyedStateBackendParametersImpl(StateBackend.KeyedStateBackendParameters<K> parameters)
-
Uses of StateBackend.KeyedStateBackendParameters in org.apache.flink.runtime.state.hashmap
Methods in org.apache.flink.runtime.state.hashmap with parameters of type StateBackend.KeyedStateBackendParameters Modifier and Type Method Description <K> AbstractKeyedStateBackend<K>
HashMapStateBackend. createKeyedStateBackend(StateBackend.KeyedStateBackendParameters<K> parameters)
-
Uses of StateBackend.KeyedStateBackendParameters in org.apache.flink.state.changelog
Methods in org.apache.flink.state.changelog with parameters of type StateBackend.KeyedStateBackendParameters Modifier and Type Method Description <K> CheckpointableKeyedStateBackend<K>
AbstractChangelogStateBackend. createKeyedStateBackend(StateBackend.KeyedStateBackendParameters<K> parameters)
-
Uses of StateBackend.KeyedStateBackendParameters in org.apache.flink.state.forst
Methods in org.apache.flink.state.forst with parameters of type StateBackend.KeyedStateBackendParameters Modifier and Type Method Description <K> ForStKeyedStateBackend<K>
ForStStateBackend. createAsyncKeyedStateBackend(StateBackend.KeyedStateBackendParameters<K> parameters)
<K> AbstractKeyedStateBackend<K>
ForStStateBackend. createKeyedStateBackend(StateBackend.KeyedStateBackendParameters<K> parameters)
-
Uses of StateBackend.KeyedStateBackendParameters in org.apache.flink.streaming.api.operators
Methods in org.apache.flink.streaming.api.operators with parameters of type StateBackend.KeyedStateBackendParameters Modifier and Type Method Description R
StreamTaskStateInitializerImpl.KeyedStateBackendCreator. create(StateBackend stateBackend, StateBackend.KeyedStateBackendParameters<K> keyedStateBackendParameters)
Create the keyed state backend. -
Uses of StateBackend.KeyedStateBackendParameters in org.apache.flink.streaming.api.operators.sorted.state
Methods in org.apache.flink.streaming.api.operators.sorted.state with parameters of type StateBackend.KeyedStateBackendParameters Modifier and Type Method Description <K> CheckpointableKeyedStateBackend<K>
BatchExecutionStateBackend. createKeyedStateBackend(StateBackend.KeyedStateBackendParameters<K> parameters)
-