Class RichGroupCombineFunction<IN,​OUT>

    • Constructor Detail

      • RichGroupCombineFunction

        public RichGroupCombineFunction()
    • Method Detail

      • combine

        public abstract void combine​(Iterable<IN> values,
                                     Collector<OUT> out)
                              throws Exception
        Description copied from interface: GroupCombineFunction
        The combine method, called (potentially multiple timed) with subgroups of elements.
        Specified by:
        combine in interface GroupCombineFunction<IN,​OUT>
        Parameters:
        values - The elements to be combined.
        out - The collector to use to return values from the function.
        Throws:
        Exception - The function may throw Exceptions, which will cause the program to cancel, and may trigger the recovery logic.