Table API问题

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

Table API问题

Chen Dan

API文档中TableEnvironment的方法scan的入参是tablePath,请问什么是tablePath?

在文档
https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/table/streaming/time_attributes.html 中看到如下示例代码:

这么看起来,UserActions是TableSource的名字,scan就是把TableSource的名字作为入参。但是当我自己按照这个方法来写的时候,却报错:

这是我的代码:


这是运行结果:


我明明把user_moid注册成TableSource,TableSource的名字作为scan的入参。