flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Szabó Péter <nemderogator...@gmail.com>
Subject Re: Streaming temporal operator (join, cross...) syntax
Date Mon, 05 Jan 2015 12:26:20 GMT
The first one looks great and more compact. I think, the second one is less
intuitive.

Cheers,
Peter

2015-01-05 10:46 GMT+01:00 Gyula Fóra <gyfora@apache.org>:

> Hey guys,
>
> We have been discussing the possible syntaxes for doing temporal operators
> on DataStreams(join, corss, cogroup etc) with Paris and we have come up
> with two alternatives.
>
> 1.
>
> ds1.join(ds2).onWindow(5, seconds).every(2,
> seconds).where(...).equalTo(...)
>
> 2.
>
> ds1.connect(ds2).onWindow(5, seconds).every(2,
> seconds).join().where(...).equalTo(...)
>
>
>
> Basically the difference is that in the second case we produce a binary
> stream of 2 types by the connect method and we create a window on that
> before join/cross. While in the first case the join/cross/etc is the method
> of the DataStream itself and we define the window after calling
> join/cross/etc
>
> We currently have the first one.
>
> Which one do you think is the more intuitive? (Or propose an alternative)
>
> Cheers,
> Gyula & Paris
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message