Error in my streamtableExample(java style),Thanks for your help

[大森林]

I want to write an StreamTableExample(java style)

of

https://github.com/apache/flink/blob/master/flink-examples/flink-examples-table/src/main/scala/org/apache/flink/table/examples/scala/basics/StreamTableExample.scala

My code is:

https://paste.ubuntu.com/p/WcBb7Rr6gb/

Could you tell me why my code is wrong?

The intellij tell me what I got is DataStreamSource, instead of DataStream,

How can I fix it?

Thanks for your help.