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 <[email protected]> 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 >
