😬 it worked Table t = tupled3DsTable .window(Session.withGap(lit(5).minutes()).on($("handlingTime")).as("w")) .groupBy($("transactionId")) .select($("handlingTime"), $("transactionId"), $("originalEvent"), $("handlingTime").sum().over($("w")));
Op di 15 feb. 2022 om 15:50 schreef Chesnay Schepler <ches...@apache.org>: > Aren't you missing a groupBy() between window() and select()? > > On 15/02/2022 15:45, HG wrote: > > Hi all, > > When I execute the code : > > Table tupled3DsTable = tableEnv.fromDataStream(tuple3ds, Schema.newBuilder() > .column("f0","TIMESTAMP_LTZ(3)") // Only > TIMESTAMP_LTZ(0) to TIMESTAMP_LTZ(3) allowed > .column("f1","STRING") > .column("f2","STRING") > .watermark("f0", "SOURCE_WATERMARK()") > .build()).as("handlingTime", "transactionId", > "originalEvent"); > > tupled3DsTable.printSchema(); > > Table t = tupled3DsTable > > .window(Session.withGap(lit(5).minutes()).on($("handlingTime")).as("w")) > .select($("handlingTime"), $("transactionId"), $("originalEvent"), > $("handlingTime").sum().over($("w"))); > > I get: > > error: cannot find symbol > .select($("handlingTime"), $("transactionId"), > $("originalEvent"), $("handlingTime").sum().over($("w"))); > ^ > symbol: method > select(org.apache.flink.table.api.ApiExpression,org.apache.flink.table.api.ApiExpression,org.apache.flink.table.api.ApiExpression,org.apache.flink.table.api.ApiExpression) > location: interface org.apache.flink.table.api.GroupWindowedTable > > The printSchema gives: > > ( > `handlingTime` TIMESTAMP_LTZ(3) *ROWTIME*, > `transactionId` STRING, > `originalEvent` STRING > > ) > > Regards Hans > > >