diff --git a/binding/src/test/java/org/mobilitydb/flink/sql/GeneratedSqlSurfaceTest.java b/binding/src/test/java/org/mobilitydb/flink/sql/GeneratedSqlSurfaceTest.java index 996170e..b4eb401 100644 --- a/binding/src/test/java/org/mobilitydb/flink/sql/GeneratedSqlSurfaceTest.java +++ b/binding/src/test/java/org/mobilitydb/flink/sql/GeneratedSqlSurfaceTest.java @@ -149,6 +149,13 @@ void arraysCrossAsFlinkArrays() throws Exception { + near + "])")); assertThrows(Exception.class, () -> scalar("SELECT intset_out(`set`(ARRAY[1, CAST(NULL AS INT)]))")); + // An array of fixed-size values reaches MEOS as the contiguous C array it reads + assertEquals("{[1, 3), [5, 7)}", scalar("SELECT intspanset_out(spanset(ARRAY[" + + "intspan_in('[5, 7)'), intspan_in('[1, 3)')]))")); + assertEquals(2, scalar("SELECT numValues(`set`(ARRAY[npoint_in('NPoint(1, 0.5)'), " + + "npoint_in('NPoint(2, 0.3)'), npoint_in('NPoint(1, 0.5)')]))")); + assertEquals(2, scalar("SELECT numValues(`set`(ARRAY[cbuffer_in('Cbuffer(Point(1 1), 0.5)'), " + + "cbuffer_in('Cbuffer(Point(2 2), 1)')]))")); } @Test