Uses of Interface
org.apache.flink.api.common.state.ValueState

Packages that use ValueState

Package	Description
org.apache.flink.api.common.functions
org.apache.flink.api.common.functions.util
org.apache.flink.api.common.state
org.apache.flink.cep.nfa.sharedbuffer
org.apache.flink.datastream.api.context
org.apache.flink.datastream.impl.context
org.apache.flink.queryablestate.client.state
org.apache.flink.runtime.state
org.apache.flink.runtime.state.internal	This package holds the classes of the internal state type hierarchy.
org.apache.flink.state.api.runtime
org.apache.flink.streaming.api.functions.query
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.windowing.triggers
org.apache.flink.streaming.runtime.operators.windowing	This package contains the operators that implement the various window operations on data streams.
org.apache.flink.table.runtime.dataview
org.apache.flink.table.runtime.functions
org.apache.flink.table.runtime.operators.deduplicate

Uses of ValueState in org.apache.flink.api.common.functions

Methods in org.apache.flink.api.common.functions that return ValueState

Modifier and Type	Method and Description
<T> ValueState<T>	RuntimeContext.getState(ValueStateDescriptor<T> stateProperties) Gets a handle to the system's key/value state.

Uses of ValueState in org.apache.flink.api.common.functions.util

Methods in org.apache.flink.api.common.functions.util that return ValueState

Modifier and Type	Method and Description
<T> ValueState<T>	AbstractRuntimeUDFContext.getState(ValueStateDescriptor<T> stateProperties)

Uses of ValueState in org.apache.flink.api.common.state

Methods in org.apache.flink.api.common.state that return ValueState

Modifier and Type	Method and Description
<T> ValueState<T>	KeyedStateStore.getState(ValueStateDescriptor<T> stateProperties) Gets a handle to the system's key/value state.

Uses of ValueState in org.apache.flink.cep.nfa.sharedbuffer

Methods in org.apache.flink.cep.nfa.sharedbuffer with parameters of type ValueState

Modifier and Type	Method and Description
void	SharedBuffer.migrateOldState(KeyedStateBackend<?> stateBackend, ValueState<NFAState> computationStates)

Uses of ValueState in org.apache.flink.datastream.api.context

Methods in org.apache.flink.datastream.api.context that return types with arguments of type ValueState

Modifier and Type	Method and Description
<T> Optional<ValueState<T>>	StateManager.getState(ValueStateDeclaration<T> stateDeclaration) Get the specific value state.

Uses of ValueState in org.apache.flink.datastream.impl.context

Methods in org.apache.flink.datastream.impl.context that return types with arguments of type ValueState

Modifier and Type	Method and Description
<T> Optional<ValueState<T>>	DefaultStateManager.getState(ValueStateDeclaration<T> stateDeclaration)

Uses of ValueState in org.apache.flink.queryablestate.client.state

Classes in org.apache.flink.queryablestate.client.state that implement ValueState

Modifier and Type	Class and Description
class	ImmutableValueState<V> A read-only ValueState that does not allow for modifications.

Uses of ValueState in org.apache.flink.runtime.state

Methods in org.apache.flink.runtime.state that return ValueState

Modifier and Type	Method and Description
<T> ValueState<T>	DefaultKeyedStateStore.getState(ValueStateDescriptor<T> stateProperties)

Uses of ValueState in org.apache.flink.runtime.state.internal

Subinterfaces of ValueState in org.apache.flink.runtime.state.internal

Modifier and Type	Interface and Description
interface	InternalValueState<K,N,T> The peer to the ValueState in the internal state type hierarchy.

Uses of ValueState in org.apache.flink.state.api.runtime

Methods in org.apache.flink.state.api.runtime that return ValueState

Modifier and Type	Method and Description
<T> ValueState<T>	SavepointRuntimeContext.getState(ValueStateDescriptor<T> stateProperties)

Uses of ValueState in org.apache.flink.streaming.api.functions.query

Constructor parameters in org.apache.flink.streaming.api.functions.query with type arguments of type ValueState

Constructor and Description
QueryableValueStateOperator(String registrationName, StateDescriptor<ValueState<IN>,IN> stateDescriptor)

Uses of ValueState in org.apache.flink.streaming.api.operators

Methods in org.apache.flink.streaming.api.operators that return ValueState

Modifier and Type	Method and Description
<T> ValueState<T>	StreamingRuntimeContext.getState(ValueStateDescriptor<T> stateProperties)

Uses of ValueState in org.apache.flink.streaming.api.windowing.triggers

Methods in org.apache.flink.streaming.api.windowing.triggers that return ValueState

Modifier and Type	Method and Description
<S extends Serializable> ValueState<S>	Trigger.TriggerContext.getKeyValueState(String name, Class<S> stateType, S defaultState) Deprecated. Use Trigger.TriggerContext.getPartitionedState(StateDescriptor).
<S extends Serializable> ValueState<S>	Trigger.TriggerContext.getKeyValueState(String name, TypeInformation<S> stateType, S defaultState) Deprecated. Use Trigger.TriggerContext.getPartitionedState(StateDescriptor).

Uses of ValueState in org.apache.flink.streaming.runtime.operators.windowing

Methods in org.apache.flink.streaming.runtime.operators.windowing that return ValueState

Modifier and Type	Method and Description
<S extends Serializable> ValueState<S>	WindowOperator.Context.getKeyValueState(String name, Class<S> stateType, S defaultState)
<S extends Serializable> ValueState<S>	WindowOperator.Context.getKeyValueState(String name, TypeInformation<S> stateType, S defaultState)
<T> ValueState<T>	WindowOperator.MergingWindowStateStore.getState(ValueStateDescriptor<T> stateProperties)

Uses of ValueState in org.apache.flink.table.runtime.dataview

Methods in org.apache.flink.table.runtime.dataview that return ValueState

Modifier and Type	Method and Description
protected ValueState<EV>	StateMapView.KeyedStateMapViewWithKeysNullable.getNullState()
protected ValueState<EV>	StateMapView.NamespacedStateMapViewWithKeysNullable.getNullState()

Constructors in org.apache.flink.table.runtime.dataview with parameters of type ValueState

Constructor and Description
KeyedStateMapViewWithKeysNullable(MapState<EK,EV> mapState, ValueState<EV> nullState)

Uses of ValueState in org.apache.flink.table.runtime.functions

Methods in org.apache.flink.table.runtime.functions with parameters of type ValueState

Modifier and Type	Method and Description
default void	CleanupState.registerProcessingCleanupTimer(ValueState<Long> cleanupTimeState, long currentTime, long minRetentionTime, long maxRetentionTime, TimerService timerService)

Uses of ValueState in org.apache.flink.table.runtime.operators.deduplicate

Methods in org.apache.flink.table.runtime.operators.deduplicate with parameters of type ValueState

Modifier and Type	Method and Description
static void	RowTimeDeduplicateFunction.deduplicateOnRowTime(ValueState<RowData> state, RowData currentRow, Collector<RowData> out, boolean generateUpdateBefore, boolean generateInsert, int rowtimeIndex, boolean keepLastRow) Processes element to deduplicate on keys with row time semantic, sends current element if it is last or first row, retracts previous element if needed.