pyflink.datastream.functions.RuntimeContext.get_reducing_state

abstract RuntimeContext.get_reducing_state(state_descriptor: pyflink.datastream.state.ReducingStateDescriptor) → pyflink.datastream.state.ReducingState

Gets a handle to the system’s key/value reducing state. This state is similar to the state accessed via get_state(ValueStateDescriptor), but is optimized for state that aggregates values.

This state is only accessible if the function is executed on a KeyedStream.