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

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

Operation of Windows and Triggers

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

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

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

Custom Trigger Implementation

stub         return TriggerResult.CONTINUE;     }         public static TradeTrigger of() {         return new TradeTrigger<>();     }     }  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

Understanding Sliding Windows

threshold has passed? What do these results signify? 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

Accessing elements from DataStream

ction on DataStreams like in WindowedStreams. Is there any other way? 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

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: 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

Using FlinkML algorithms in Streaming

gards,Piyush Shrivastava http://webograffiti.com

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