🎉 Apache Sedona 1.9.1 已正式发布!🗺️ 新增 Geography SQL 函数、Box2D 与 Box3D 类型、栅格 Python UDF 等。查看发布说明 →

安装 Sedona Scala/Java

在开始 Sedona 之旅之前,请确保您的 Apache Flink 集群已就绪。

随后即可创建一个独立的 Scala / Java 项目。独立项目可以让您创建多个 Scala / Java 文件,并将复杂的逻辑集中实现。

要在独立的 Flink 项目中使用 Sedona,只需在 pom.xmlbuild.sbt 中将 Sedona 添加为依赖。

  1. 关于如何添加 Sedona 依赖,请参阅 Sedona Maven Central 坐标
  2. 阅读 Sedona Flink 指南,并使用 Sedona 模板项目快速上手:Sedona 模板项目
  3. 使用 Maven 编译您的项目,并确保得到打包了所有依赖的 fat jar。
  4. 将编译生成的 fat jar 提交到 Flink 集群。请确保位于 Flink 发行版的根目录,然后运行以下命令:
./bin/flink run /Path/To/YourJar.jar