Uses of Class
org.apache.flink.api.common.state.ReducingStateDescriptor

Packages that use ReducingStateDescriptor

Package	Description
org.apache.flink.api.common.functions
org.apache.flink.api.common.functions.util
org.apache.flink.api.common.state
org.apache.flink.runtime.state
org.apache.flink.streaming.api.datastream
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 ReducingStateDescriptor in org.apache.flink.api.common.functions

Methods in org.apache.flink.api.common.functions with parameters of type ReducingStateDescriptor

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 ReducingStateDescriptor in org.apache.flink.api.common.functions.util

Methods in org.apache.flink.api.common.functions.util with parameters of type ReducingStateDescriptor

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

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

Methods in org.apache.flink.api.common.state with parameters of type ReducingStateDescriptor

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 ReducingStateDescriptor in org.apache.flink.runtime.state

Methods in org.apache.flink.runtime.state with parameters of type ReducingStateDescriptor

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

Uses of ReducingStateDescriptor in org.apache.flink.streaming.api.datastream

Methods in org.apache.flink.streaming.api.datastream with parameters of type ReducingStateDescriptor

Modifier and Type	Method and Description
QueryableStateStream<KEY,T>	KeyedStream.asQueryableState(String queryableStateName, ReducingStateDescriptor<T> stateDescriptor) Publishes the keyed stream as a queryable ReducingState instance.

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

Methods in org.apache.flink.streaming.api.operators with parameters of type ReducingStateDescriptor

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

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

Methods in org.apache.flink.streaming.runtime.operators.windowing with parameters of type ReducingStateDescriptor

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