Re: [DISCUSS] Add Side Input/Broadcast Set For Streaming API

2016-12-20 Thread Gábor Gévay
you can find my few thoughts about this feature (a.k.a. my >> > attempt to extend Aljoscha's initial document). >> > I hope you will find it interesting and a good starting point for >> > having a new FLIP soon ;-) >> > >> > Cheers, >> > Ventu

Re: [DISCUSS] Add Side Input/Broadcast Set For Streaming API

2016-11-08 Thread 吕文龙
FLIP soon ;-) > > > > Cheers, > > Ventura > > > > > > > > -- > > View this message in context: > > http://apache-flink-mailing-list-archive.1008284.n3. > nabble.com/DISCUSS-Add-Side-Input-Broadcast-Set-For- > Streaming-API-tp11529p14287.html > > Sent from the Apache Flink Mailing List archive. mailing list archive at > > Nabble.com. > > >

Re: [DISCUSS] Add Side Input/Broadcast Set For Streaming API

2016-11-01 Thread Aljoscha Krettek
pt to extend Aljoscha's initial document). > I hope you will find it interesting and a good starting point for > having a new FLIP soon ;-) > > Cheers, > Ventura > > > > -- > View this message in context: > http://apache-flink-mailing-list-archive.1008284.n3.nabble.c

Re: [DISCUSS] Add Side Input/Broadcast Set For Streaming API

2016-10-28 Thread venturadelmonte
84.n3.nabble.com/DISCUSS-Add-Side-Input-Broadcast-Set-For-Streaming-API-tp11529p14287.html Sent from the Apache Flink Mailing List archive. mailing list archive at Nabble.com.

Re: [DISCUSS] Add Side Input/Broadcast Set For Streaming API

2016-05-02 Thread Aljoscha Krettek
Hi Folks, I added a section about "Implementation Details" to the doc, it is still very rough but I'm afraid this is somewhat tricky and might require some changes to how we handle state. As always, feedback is very welcome! Cheers, Aljoscha On Mon, 2 May 2016 at 11:28 Aljoscha Krettek

[DISCUSS] Add Side Input/Broadcast Set For Streaming API

2016-05-02 Thread Aljoscha Krettek
Hi, I've put down some words about how we would go about adding support for side inputs to the streaming API. People are increasingly asking for such a feature, which would allow joining a main stream with some slowly changing inputs that can be used for enriching data, among other things. The