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 wrote: Hey Piyush, Would you like to train or predict on the streaming data? Best, Marton On Wed, May 11, 2016 at 3:44 PM

Using FlinkML algorithms in Streaming

gards,Piyush Shrivastava http://webograffiti.com

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 wrote: Hello all, I have a time series based logic written with Flink. Due to the parallelism, I am not getting the output in a proper

Sorted output

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 wrote: Hi, you can just use a flatMap() on a DataStream to access individual elements from a

Accessing elements from DataStream

ction 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 wrote: Piyush, You created sliding window witch is triggered every 10 seconds Flink fires up this window every 10 seconds, without waiting at 5 min buffer to be filled up It

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 wrote: Hi, Let me also add that you should also override the clear() method in order to clear you state.and delete the pending

Custom Trigger Implementation

stub         return TriggerResult.CONTINUE;     }         public static TradeTrigger of() {         return new TradeTrigger<>();     }     }  Thanks and Regards,Piyush Shrivastava http://webograffiti.com

Re: Operation of Windows and Triggers

shda",85.930) 1> (2,"poorvi",23.15) flag: true count: 0 flag: true count: 1 flag: true count: 2... Thanks and Regards,Piyush Shrivastava http://webograffiti.com On Wednesday, 20 April 2016 10:26 PM, Aljoscha Krettek wrote: Just to clarify, the state of a Trigger on Global

Re: Operation of Windows and Triggers

/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/CountTrigger.java What changes do I need to make? Is it even possible to do this?  Thanks and Regards,Piyush Shrivastava http://webograffiti.com On Wednesday, 20 April 2016 4:59 PM

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 wrote: #yiv9940457293

Custom time window in Flink

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