> Hi,
>
>
>
> 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)); } });|
>
>
>
> Regards,
>
>
>
> Radu
>
>
>