Hi,
When I do :
Table counts = t
.groupBy($("transactionId"))
.select($("transactionId"),
$("handlingTime").sum().as("summedhandlingTime"));
The code below fails with :
cannot find symbol
.select($("transactionId"),
$("handlingTime").sum().as("summedhandlingTime"));
^
symbol: method $(java.lang.String)
location: class esl.job.cag.verwerkingstijden.CagVerwerkingsTijden
The same is true when I copy the code below from
https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/table/common/
DataStream<Tuple2<Integer, String>> stream1 =
env.fromElements(new Tuple2<>(1, "hello"));
DataStream<Tuple2<Integer, String>> stream2 =
env.fromElements(new Tuple2<>(1, "hello"));
// explain Table API
Table table1 = tableEnv.fromDataStream(stream1, $("count"), $("word"));
Table table2 = tableEnv.fromDataStream(stream2, $("count"), $("word"));
Table table = table1
.where($("word").like("F%"))
.unionAll(table2);
Anyone a clue?
Regards Hans
