这里指定 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)