Class ReducingStateDescriptor<T>

    • Constructor Detail

      • ReducingStateDescriptor

        public ReducingStateDescriptor​(String name,
                                       ReduceFunction<T> reduceFunction,
                                       TypeInformation<T> typeInfo)
        Creates a new ReducingStateDescriptor with the given name and default value.
        Parameters:
        name - The (unique) name for the state.
        reduceFunction - The ReduceFunction used to aggregate the state.
        typeInfo - The type of the values in the state.
      • ReducingStateDescriptor

        public ReducingStateDescriptor​(String name,
                                       ReduceFunction<T> reduceFunction,
                                       TypeInformation<T> typeInfo,
                                       SerializerConfig serializerConfig)
        Creates a new ReducingStateDescriptor with the given name and default value.
        Parameters:
        name - The (unique) name for the state.
        reduceFunction - The ReduceFunction used to aggregate the state.
        typeInfo - The type of the values in the state.