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)
