You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sedona.apache.org by ji...@apache.org on 2024/05/18 07:03:29 UTC
(sedona) 01/01: Update example projects
This is an automated email from the ASF dual-hosted git repository.
jiayu pushed a commit to branch example-project
in repository https://gitbox.apache.org/repos/asf/sedona.git
commit a4c61345cd95de905694d3cf80823f082c995887
Author: Jia Yu <ji...@apache.org>
AuthorDate: Sat May 18 00:03:20 2024 -0700
Update example projects
---
examples/flink-sql/pom.xml | 4 ++--
examples/flink-sql/src/main/java/FlinkExample.java | 4 ++--
examples/spark-sql/pom.xml | 2 +-
3 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/examples/flink-sql/pom.xml b/examples/flink-sql/pom.xml
index 5ac89ed8b..00e1672bd 100644
--- a/examples/flink-sql/pom.xml
+++ b/examples/flink-sql/pom.xml
@@ -28,10 +28,10 @@
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
- <geotools.version>1.5.1-28.2</geotools.version>
+ <geotools.version>1.6.0-28.2</geotools.version>
<geotools.scope>compile</geotools.scope>
<scala.compat.version>2.12</scala.compat.version>
- <sedona.version>1.5.1</sedona.version>
+ <sedona.version>1.6.0</sedona.version>
<flink.version>1.14.3</flink.version>
<flink.scope>compile</flink.scope>
</properties>
diff --git a/examples/flink-sql/src/main/java/FlinkExample.java b/examples/flink-sql/src/main/java/FlinkExample.java
index d39c34b78..7b5a02cec 100644
--- a/examples/flink-sql/src/main/java/FlinkExample.java
+++ b/examples/flink-sql/src/main/java/FlinkExample.java
@@ -21,6 +21,7 @@ import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.table.api.EnvironmentSettings;
import org.apache.flink.table.api.Table;
import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;
+import org.apache.sedona.flink.SedonaContext;
import org.apache.sedona.flink.SedonaFlinkRegistrator;
import org.apache.sedona.flink.expressions.Constructors;
@@ -38,8 +39,7 @@ public class FlinkExample
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
EnvironmentSettings settings = EnvironmentSettings.newInstance().inStreamingMode().build();
StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env, settings);
- SedonaFlinkRegistrator.registerType(env);
- SedonaFlinkRegistrator.registerFunc(tableEnv);
+ SedonaContext.create(env, tableEnv);
// Create a fake WKT string table source
Table pointWktTable = Utils.createTextTable(env, tableEnv, Utils.createPointWKT(testDataSize), pointColNames);
diff --git a/examples/spark-sql/pom.xml b/examples/spark-sql/pom.xml
index 7826d0c83..4b601f3b8 100644
--- a/examples/spark-sql/pom.xml
+++ b/examples/spark-sql/pom.xml
@@ -39,7 +39,7 @@
<spark.version>3.4.0</spark.version>
<spark.compat.version>3.4</spark.compat.version>
<scala.compat.version>2.12</scala.compat.version>
- <sedona.version>1.5.1</sedona.version>
+ <sedona.version>1.6.0</sedona.version>
<hadoop.version>3.3.4</hadoop.version>
</properties>