flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: Flink Streaming ContinuousTimeTriggers
Date Thu, 03 Mar 2016 16:34:16 GMT
Hi,
sorry for the long wait, we are currently very busy with finalizing the 1.0 release.

I think I don’t yet completely get your use case. Could you maybe give some example input
data and what the expected behavior would be? And maybe some code? If you already have coded
something.

Cheers,
Aljoscha
> On 25 Feb 2016, at 13:46, Ankur Sharma <ankur@stud.uni-saarland.de> wrote:
> 
> Hello,
> 
> Thanks for the reply.
> 
> Target: I have a stream of tuples(append-only, no updates) that are appended to a file.
These records have priority that is changing over time and is calculated as a function of
the tuple’s timestamp and current system time. Once any tuple’s priority reaches some
MIN, I want to throw it away.
> Using this priority I want to select the next job (given by tuple) that is scheduled.
These tasks have to be periodically scheduled until they are removed from the queue completely.
> 
> Let me know if something is unclear.
> 
> Best,
> Ankur Sharma
> Information Systems Group
> 3.15 E1.1 Universität des Saarlandes
> 66123, Saarbrücken Germany
> Email: ankur.sharma@mpi-inf.mpg.de 
>             ankur@stud.uni-saarland.de
> 
>> On 25 Feb 2016, at 11:05, Aljoscha Krettek <aljoscha@apache.org> wrote:
>> 
>> Hi,
>> in addition to the video I would also like to point out that the Continuous triggers
should only be used with the GlobalWindows assigner. For TimeWindows the right thing to do
would be using the EventTimeTrigger (or ProcessingTimeTrigger in case you are doing processing
time windows).
>> 
>> Could you maybe go into some detail of what you are trying to achieve? Then we can
figure out what a good strategy would be.
>> 
>> Cheers,
>> Aljoscha
>>> On 25 Feb 2016, at 04:27, Gavin Lin <avidoggy@gmail.com> wrote:
>>> 
>>> Hi, 
>>> 
>>> how about this video ? 
>>> https://www.youtube.com/watch?v=T7hiwcwCXGI
>>> 
>>> Gavin.Lin
>>> 
>>> 2016-02-25 3:55 GMT+08:00 Ankur Sharma <ankur@stud.uni-saarland.de>:
>>> Hey,
>>> 
>>> Can you guide me to some example of ContinuousProcessingTimeTrigger?
>>> I want to partition input stream into TimeWindow that should fire at continuous
time interval on its on without waiting for a new element to enter the stream.
>>> Could you guide me to it?
>>> 
>>> 
>>> Thanks
>>> 
>>> Best,
>>> Ankur Sharma
>>> Information Systems Group
>>> 3.15 E1.1 Universität des Saarlandes
>>> 66123, Saarbrücken Germany
>>> Email: ankur.sharma@mpi-inf.mpg.de 
>>>            ankur@stud.uni-saarland.de
>>> 
> 


Mime
View raw message