Update example projects

apache · May 18, 2024 · a4c6134 · a4c6134
1 parent 30308e6
commit a4c6134
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git 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
@@ -21,6 +21,7 @@
 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 static void main(String[] args) {
         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
@@ -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>