Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-7837

AggregatingFunction does not work with immutable types

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Blocker
    • Resolution: Fixed
    • None
    • 1.4.0
    • API / DataStream
    • None

    Description

      Currently add() has this signature:

      void add(IN value, ACC accumulator);

      meaning that a value can only be added to an accumulator by modifying the accumulator. This should be extended to:

      ACC add(IN value, ACC accumulator);

      Attachments

        Issue Links

          is required by

          Sub-task - The sub-task of the issue FLINK-5968 Document WindowedStream.aggregate()

          • Blocker - Blocks development and/or testing work, production could not run
          • Closed

          Activity

            People

              aljoscha Aljoscha Krettek
              aljoscha Aljoscha Krettek
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: