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

Packages that use ReducingState

Package	Description
org.apache.flink.api.common.functions
org.apache.flink.api.common.functions.util
org.apache.flink.api.common.state
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.operators
org.apache.flink.streaming.runtime.operators.windowing	This package contains the operators that implement the various window operations on data streams.

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

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

Modifier and Type	Method and Description
<T> ReducingState<T>	RuntimeContext.getReducingState(ReducingStateDescriptor<T> stateProperties) Gets a handle to the system's key/value reducing state.

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

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

Modifier and Type	Method and Description
<T> ReducingState<T>	AbstractRuntimeUDFContext.getReducingState(ReducingStateDescriptor<T> stateProperties)

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

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

Modifier and Type	Method and Description
<T> ReducingState<T>	KeyedStateStore.getReducingState(ReducingStateDescriptor<T> stateProperties) Gets a handle to the system's key/value reducing state.

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

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

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

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

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

Modifier and Type	Method and Description
<T> ReducingState<T>	DefaultKeyedStateStore.getReducingState(ReducingStateDescriptor<T> stateProperties)

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

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

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

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

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

Modifier and Type	Method and Description
<T> ReducingState<T>	SavepointRuntimeContext.getReducingState(ReducingStateDescriptor<T> stateProperties)

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

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

Modifier and Type	Method and Description
<T> ReducingState<T>	StreamingRuntimeContext.getReducingState(ReducingStateDescriptor<T> stateProperties)

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

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

Modifier and Type	Method and Description
<T> ReducingState<T>	WindowOperator.MergingWindowStateStore.getReducingState(ReducingStateDescriptor<T> stateProperties)