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

Document window processing with Reduce/FoldFunction + WindowFunction

          Details

          • Type: Improvement
          • Status: Closed
          • Priority: Major
          • Resolution: Fixed
          • Affects Version/s: 1.1.0
          • Fix Version/s: 1.2.0, 1.1.2
          • Component/s: Documentation, Streaming
          • Labels:
            None

            Description

            The streaming documentation does not describe how windows can be processed with FoldFunction or ReduceFunction and a subsequent WindowFunction. This combination allows for eager window aggregation (only a single element is kept in the window) and access of the Window object, e.g., to have access to the window's start and end time.

              Attachments

                Issue Links

                links to

                Web Link GitHub Pull Request #2368

                  Activity

                    People

                    • Assignee:
                      danielblazevski Daniel Blazevski
                      Reporter:
                      fhueske Fabian Hueske
                    • Votes:
                      0 Vote for this issue
                      Watchers:
                      4 Start watching this issue

                      Dates

                      • Created:
                        Updated:
                        Resolved: