Hi Don, yes that's exactly how you use an anonymous function as a source function.
Cheers,
Till
On Tue, Dec 22, 2015 at 3:16 PM, Don Frascuchon <frascuc...@gmail.com>
wrote:
> Hello,
>
> There is a way for define a EventTimeSourceFunction with anonymous
> functions from the scala api? Like that:
>
> env.addSource[Int] {
> ctx => {
>
> ...
>
> ctx.collectWithTimestamp(i, System.currentTimeMillis())
> ...
>
> }
>
> }
>
> Thanks in advance!
>
