flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Don Frascuchon <frascuc...@gmail.com>
Subject Scala API and sources with timestamp
Date Tue, 22 Dec 2015 14:16:21 GMT
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!

Mime
View raw message