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