[FLINK-3176] Window Apply Website Example

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

Environment

markdown, jekyll

• Assignee: Unassigned
• Reporter: radu
• Created: 16/Dec/15 03:03
• Updated: 01/Nov/22 09:36
• Resolved: 07/Jan/16 18:03

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