Yep that should do it, perhaps are you willing to contribute to that docs
page adding the import? :)
On Mon, Feb 14, 2022 at 4:34 PM HG <hanspeter.sl...@gmail.com> wrote:
> The static was missing 😑😑😑
>
> import static org.apache.flink.table.api.Expressions.*;
>
>
>
>
> Op ma 14 feb. 2022 om 15:45 schreef Francesco Guardiani <
> france...@ververica.com>:
>
>> > symbol: method $(java.lang.String)
>> > location: class esl.job.cag.verwerkingstijden.CagVerwerkingsTijden
>>
>> What is esl.job.cag.verwerkingstijden.CagVerwerkingsTijden? Sounds like
>> a bad import? Also, have you checked you have Flink deps aligned?
>>
>> On Mon, Feb 14, 2022 at 3:17 PM HG <hanspeter.sl...@gmail.com> wrote:
>>
>>>
>>> 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
>>>
>>>
