ut)
throws Exception {
Thread.sleep(1000);
for(int i=0 ;ihttp://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Regarding-Broadcast-of-datasets-in-streaming-context-tp6456p6932.html
Sent from the Apache Flink User Mailing List archive. mai
t:
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Regarding-Broadcast-of-datasets-in-streaming-context-tp6456p6928.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> at Nabble.com.
>
message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Regarding-Broadcast-of-datasets-in-streaming-context-tp6456p6928.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
d but i again dont
understand how i can push all of the changes back.
a small example or code snippet would really be helpful.
Thanks a lot
Regards
Biplob
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Regarding-Broadcast-of-datasets-i
MyCoFlatmap)
>> >> >> inputsAndCentroids.closeWith(updatedCentroids.broadcast())
>> >> >>
>> >> >> MyCoFlatmap would be a CoFlatMapFunction which on 1 input receive
>> >> events
>>
t;> >> and update its local centroids (and periodically output the
> centroids)
> >> >> and
> >> >> on the other input would send centroids of other flatmaps and would
> >> merge
> >> >> them to the local.
> >> >>
gt;
>> >> Cheers,
>> >> Gyula
>> >>
>> >>
>> >> Biplob Biswas <
>>
>> >> revolutionisme@
>>
>> >> > ezt írta (időpont: 2016. ápr. 28.,
>> >> Cs, 14:41):
>> >>
>>
y
> >>> work.
> >>> Thanks a lot.
> >>>
> >>>
> >>> Aljoscha Krettek wrote
> >>> > Hi Biplob,
> >>> > one of our developers had a stream clustering example a while back.
> It
> >>> was
> >>
email so that he will notice and can
>>> send
>>> > you the example.
>>> >
>>> > Cheers,
>>> > Aljoscha
>>> >
>>> > On Thu, 28 Apr 2016 at 13:57 Biplob Biswas <
>>>
>>> > revolutionisme@
>>>
>>
t;> get
>> >> the
>> >> following:
>> >>
>> >> broadcast()
>> >> Sets the partitioning of the DataStream so that the output elements
>> are
>> >> broadcasted to every parallel instance of the next operation.
>> >&g
ements are
> >> broadcasted to every parallel instance of the next operation.
> >>
> >> If the output elements are broadcasted, then how are they retrieved? Or
> >> maybe I am looking at this method in a completely wrong way?
> >>
> >> Thanks
&
ry parallel instance of the next operation.
>>
>> If the output elements are broadcasted, then how are they retrieved? Or
>> maybe I am looking at this method in a completely wrong way?
>>
>> Thanks
>> Biplob Biswas
>>
>>
>>
>> --
>> View
View this message in context:
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Regarding-Broadcast-of-datasets-in-streaming-context-tp6456p6543.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> at Nabble.com.
>
-datasets-in-streaming-context-tp6456p6543.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
ache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Regarding-Broadcast-of-datasets-in-streaming-context-tp6456.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
15 matches
Mail list logo
