Scala API and sources with timestamp

[Don Frascuchon]

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!