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

Window Apply Website Example

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Closed
    • Priority: Trivial
    • Resolution: Fixed
    • Affects Version/s: 0.10.1
    • Fix Version/s: 0.10.1, 1.0.0
    • Component/s: Project Website
    • Labels:
    • Environment:

      markdown, jekyll

      Description

      I believe i found 2 small inconsistencies in the documentation for the description of Window Apply
      https://ci.apache.org/projects/flink/flink-docs-release-0.10/apis/streaming_guide.html#windows-on-unkeyed-data-streams

      1) in the example provided I believe it should be corrected to remove the extra > and add ")":

      (new WindowFunction<Tuple2<String,Integer>,Integer, Tuple, Window>() {
      ...
      });
      instead of

      (new WindowFunction<Tuple2<String,Integer>,Integer>, Tuple, Window>() {
      ...
      };

      2) for AllWindowedStream it seems there is a need for a AllWindowFunction not a WindowFunction
      I would propose to duplicate the existing example to cover also this case, particularly that it has a slightly different interface

      allWindowedStream.apply (new AllWindowFunction<Tuple2<String,Integer>,Integer, TimeWindow>() {
      public void apply (TimeWindow window,
      Iterable<Tuple2<String, Integer>> values,
      Collector<Integer> out) throws Exception {
      int sum = 0;
      for (value t: values)

      { sum += t.f1; }

      out.collect (new Integer(sum));
      }
      });

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              rtudoran radu
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved:

                Time Tracking

                Estimated:
                Original Estimate - 336h
                336h
                Remaining:
                Remaining Estimate - 336h
                336h
                Logged:
                Time Spent - Not Specified
                Not Specified