Apache Flink TableEnvironment中的方法

4xrmg8kj  于 6个月前  发布在  Apache
关注(0)|答案(1)|浏览(54)

我试着开始使用Flink。但是在编码时有一个问题

EnvironmentSettings settings = EnvironmentSettings
  .newInstance()
  .inStreamingMode()
  //.inBatchMode()
  .build();

TableEnvironment tEnv = TableEnvironment.create(settings);

tEnv.executeSql(""); // This gets me error can't resolve executesql
TableResult result = tEnv.executeSql(""); // This will work

字符串
我首先想到的是,因为这个方法有一个返回类型,所以我们应该分配它。但是如果我使用了返回类型为void的东西,问题仍然是一样的

oug3syen

oug3syen1#

我不知道你的问题到底是什么,但是如果你的SQL查询不包含任何内容(""),那么得到空结果或错误也不必感到惊讶。
它应该是这样的:

tEnv.executeSql("SELECT * FROM yourTableName")

字符串
例如:link
读一些documentation它可以帮助

相关问题