That's the main function.
I have no idea what imports are missing.
I am able to use the SQL API for the table.
When I switch to .select (()) where(()) groupBy(()) I get this error.
On Mon, Feb 14, 2022, 15:45 Francesco Guardiani <france...@ververica.com>
wrote:
> > 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
>>
>>
