f)
User(f.split(",")(0), f.split(",")(1).toInt, f.split(",")(2).toLong)
})
.assignTimestampsAndWatermarks...println(f)
User(f.split(",")(0), f.split(",")(1).toInt, f.split(",")(2).toLong)
})
.assignTimestampsAndWatermarks...println(f)
User(f.split(",")(0), f.split(",")(1).toInt, f.split(",")(2).toLong)
})
.assignTimestampsAndWatermarks...f)
User(f.split(",")(0), f.split(",")(1).toInt, f.split(",")(2).toLong)
})
.assignTimestampsAndWatermarks