Re: Using FlinkML algorithms in Streaming

Hi Márton, I want to train and get the residuals.  Thanks and Regards,Piyush Shrivastava http://webograffiti.com On Wednesday, 11 May 2016 7:19 PM, Márton Balassi <balassi.mar...@gmail.com> wrote: Hey Piyush, Would you like to train or predict on the streaming data? Best, Marton

Re: Sorted output

This is now solved, thank you. :-)  Thanks and Regards,Piyush Shrivastava http://webograffiti.com On Monday, 9 May 2016 3:47 PM, Piyush Shrivastava <piyush...@yahoo.co.in> wrote: Hello all, I have a time series based logic written with Flink. Due to the parallelism, I am not g

Sorted output

er. I am using TimeWindow and apply (WindowFunction) functionalities. How can I sort the output?  Thanks and Regards,Piyush Shrivastava http://webograffiti.com

Re: Accessing elements from DataStream

Hi Robert, Can you share an example where flatmap is used to access elements?  Thanks and Regards,Piyush Shrivastava http://webograffiti.com On Thursday, 5 May 2016 4:45 PM, Robert Metzger <rmetz...@apache.org> wrote: Hi, you can just use a flatMap() on a DataStream to access indi

Accessing elements from DataStream

ion on DataStreams like in WindowedStreams. Is there any other way? Thanks and Regards,Piyush Shrivastava http://webograffiti.com

Re: Understanding Sliding Windows

? Thanks and Regards,Piyush Shrivastava http://webograffiti.com On Tuesday, 26 April 2016 8:54 PM, Dominik Choma <dominik.ch...@gmail.com> wrote: Piyush, You created sliding window witch is triggered every 10 seconds Flink fires up this window every 10 seconds, without waiting at

Understanding Sliding Windows

threshold has passed? What do these results signify? Thanks and Regards,Piyush Shrivastava http://webograffiti.com

Re: Custom Trigger Implementation

Thanks a lot Kostas. This solved my problem. Thanks and Regards,Piyush Shrivastava http://webograffiti.com On Monday, 25 April 2016 3:27 PM, Kostas Kloudas <k.klou...@data-artisans.com> wrote: Hi, Let me also add that you should also override the clear() method in order to cle

Operation of Windows and Triggers

has passed, 100 messages are passed? Thanks and Regards,Piyush Shrivastava http://webograffiti.com

Re: Custom time window in Flink

Hello,Thanks a lot for your reply. Can you share a sample code or example which I can refer while creating a custom evictor and trigger? Thanks and Regards,Piyush Shrivastava http://webograffiti.com On Wednesday, 20 April 2016 2:50 PM, Radu Tudoran <radu.tudo...@huawei.com>

Custom time window in Flink

you kindly help me with this? How can such a functionality be implemented?  Thanks and Regards,Piyush Shrivastava http://webograffiti.com