[jira] [Created] (FLINK-3176) Window Apply Website Example

["radu (JIRA)" <ji...@apache.org>]

radu created FLINK-3176:
---------------------------

             Summary: Window Apply Website Example
                 Key: FLINK-3176
                 URL: https://issues.apache.org/jira/browse/FLINK-3176
             Project: Flink
          Issue Type: Improvement
          Components: website
    Affects Versions: 0.10.1
         Environment: markdown, jekyll
            Reporter: radu
            Priority: Trivial
             Fix For: 0.10.1


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));
    }
});



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)