安装 Sedona Scala/Java
在开始 Sedona 之旅之前,请确保您的 Apache Flink 集群已就绪。
随后即可创建一个独立的 Scala / Java 项目。独立项目可以让您创建多个 Scala / Java 文件,并将复杂的逻辑集中实现。
要在独立的 Flink 项目中使用 Sedona,只需在 pom.xml 或 build.sbt 中将 Sedona 添加为依赖。
- 关于如何添加 Sedona 依赖,请参阅 Sedona Maven Central 坐标
- 阅读 Sedona Flink 指南,并使用 Sedona 模板项目快速上手:Sedona 模板项目
- 使用 Maven 编译您的项目,并确保得到打包了所有依赖的 fat jar。
- 将编译生成的 fat jar 提交到 Flink 集群。请确保位于 Flink 发行版的根目录,然后运行以下命令:
./bin/flink run /Path/To/YourJar.jar