Add flink test case

apache · Jun 24, 2023 · 285f7a9 · 285f7a9
1 parent 42951c0
commit 285f7a9
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/flink/src/test/java/org/apache/sedona/flink/FunctionTest.java b/flink/src/test/java/org/apache/sedona/flink/FunctionTest.java
@@ -745,4 +745,14 @@ public void testBoundingDiagonal() {
         assertEquals(expected, actual);
     }
 
+    @Test
+    public void testAngle() {
+        Table polyTable = tableEnv.sqlQuery("SELECT ST_Angle(ST_GeomFromWKT('LINESTRING (0 0, 1 1)'), ST_GeomFromWKT('LINESTRING (0 0, 3 2)'))" + " AS " + polygonColNames[0]);
+        polyTable = polyTable.select(call(Functions.ST_Degrees.class.getSimpleName(), $(polygonColNames[0])));
+        Double expected = 11.309932474020195;
+        Double actual = (Double) first(polyTable).getField(0);
+        assertEquals(expected, actual, 1e-9);
+
+    }
+
 }