😬
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 <[email protected]>:
> 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
>
>
>
