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