flink table api 定义时间字段

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

 

flink table api 定义时间字段

上一篇:photoshop鼠绘一个逼真的红色心形礼物盒子


下一篇:精美的创意商业标志