Flink的Table API使用找不到$的依赖

Question

Flink的TableEnvironment使用中找不到$的依赖

注入的依赖

代码

代码片段1

代码片段2

目前的猜测，可能是依赖注入问题，但是目前没找到问题具体出现在哪里。

Answer 1

以下回复参考：皆我百晓生、券券喵儿等免费微信小程序作答:

根据你提供的描述和代码片段，我注意到了一些可能的问题。在 Flink 的 Table API 中，你似乎在尝试使用 $ 符号来选择字段，但是这个符号实际上是 Flink SQL API 中的一部分，而不是 Table API 的直接部分。在 Table API 中，你应该使用其他方式来选择和操作字段。

此外，根据你提供的依赖列表，看起来你已经添加了正确的 Flink 相关依赖。但是，如果在实际运行代码时遇到问题，可能是由于以下原因之一：

1. 版本冲突：确保你使用的 Flink 版本与其他依赖项兼容。例如，如果你使用的是 Flink 1.16.3 版本，确保其他依赖项也是针对这个版本的。
2. 依赖注入问题：确保你的项目正确注入了所有必要的依赖项。检查项目的构建文件（如 Maven 的 pom.xml 或 Gradle 的 build.gradle），确保所有依赖项都已正确声明。
3. IDE 问题：有时，IDE 可能无法正确识别或同步依赖项。尝试清理并重建你的项目，或者重新导入依赖项。

针对你提供的代码片段，如果你想要使用 Flink Table API 进行操作，你可以尝试以下方式：

// 创建流执行环境和 TableEnvironment
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
EnvironmentSettings settings = EnvironmentSettings.newInstance().inStreamingMode().build();
TableEnvironment tableEnv = TableEnvironment.create(env, settings);

// 创建 Table API 的 Table 对象并进行操作
Table myTable = ...; // 你的表数据
Table filteredTable = myTable.filter("id > 100"); // 使用 filter 方法进行过滤操作

请注意，上述代码只是一个示例，你需要根据你的实际情况进行适当的调整。如果你仍然遇到问题，请提供更多关于错误消息和代码的详细信息，以便我能更准确地帮助你解决问题。