pyflink.datastream.functions.RuntimeContext.get_aggregating_state

abstract RuntimeContext.get_aggregating_state(state_descriptor: pyflink.datastream.state.AggregatingStateDescriptor) → pyflink.datastream.state.AggregatingState

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

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