when converting a DataStream (with Watermarks) to a table like described here
I wonder on how to use the rowtime in a following window operation _without_ explicitly specifying all field names and hence rely on case class type inference.
Currently when operating on a stream of events
case class Event(field1: String, ts: long)
val ds: DataStream[Event] = ...
I have to do
tableEnv.fromDataStream(ds, 'field1, 'ts, 'myRowtime.rowtime)
.window(Tumble over 1.hours on 'myRowtime as 'w)
afterwards. Is there a way to create the TimeAttribute column without specifiying all fields again?
Thanks for yout help,