Interface TableAggsHandleFunction

    • Method Detail

      • emitValue

        void emitValue​(Collector<RowData> out,
                       RowData currentKey,
                       boolean isRetract)
                throws Exception
        Emit the result of the table aggregation through the collector.
        Parameters:
        out - the collector used to emit records.
        currentKey - the current group key.
        isRetract - the retraction flag which indicates whether emit retract values.
        Throws:
        Exception