这里指定 id, name 两个字段，并指定 age 字段作为事件时间字段。
tableEnv.connect() .withSchema(new Schema() .field("id", DataTypes.INT()) .rowtime(new Rowtime() .timestampsFromField("age") .watermarksPeriodicBounded(1000)) .field("name", DataTypes.STRING()))
指定 age 为事件事件，新增 pt 为处理时间，pt 字段是可以自定义的
val tPerson: Table = tableEnv.fromDataStream(dsPerson, ‘name, ‘age.rowtime, ‘pt.proctime)
原文：https://www.cnblogs.com/wudeyun/p/14848041.html