flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Kamil Gorlo <kgo...@gmail.com>
Subject Re: Hello World Flink 0.10
Date Fri, 13 Nov 2015 10:29:54 GMT
OK, so as far as I understand the line ".trigger(new EOFTrigger)" is simply
not needed in this case (it looks that it works as expected when I remove
it).

Thanks for your help.

pt., 13.11.2015 o 11:01 u┼╝ytkownik Robert Metzger <rmetzger@apache.org>
napisał:

> Hi Kamil,
>
> The EOFTrigger is not part of Flink.
> However, I've also tried implementing the Hello World from the
> presentation here:
> https://github.com/rmetzger/scratch/blob/flink0.10-scala2.11/src/main/scala/com/dataartisans/Job.scala
>
> Stephan Ewen told me that there is a more elegant way of implementing
> this: The trigger is actually not needed because windows trigger when they
> are closed (and they are closed when the file has been read). So you can
> also remove my hack of emitting a fake record at the end of the read
> process in the close() method.
>
>
>
> On Fri, Nov 13, 2015 at 10:52 AM, Kamil Gorlo <kgorlo@gmail.com> wrote:
>
>> Hi guys,
>>
>> I was trying to implement Hello World from slide 36 from
>> http://www.slideshare.net/FlinkForward/k-tzoumas-s-ewen-flink-forward-keynote
>>
>> but I have problem with EOFTrigger - is it something I should implement
>> by myself? I cannot find it in Flink libraries.
>>
>> Cheers,
>> Kamil
>>
>
>

Mime
View raw message