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

Reply via email to