This is an automated email from the ASF dual-hosted git repository. anton pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push: new b74cb17 [SQL] Add array constructor test new e8666a4 Merge pull request #8727 from akedin/array-constructor b74cb17 is described below commit b74cb17b4d3893611eb853775ff6d2528f8a1adf Author: akedin <ke...@google.com> AuthorDate: Thu May 30 10:22:20 2019 -0700 [SQL] Add array constructor test --- .../apache/beam/sdk/extensions/sql/BeamComplexTypeTest.java | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/BeamComplexTypeTest.java b/sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/BeamComplexTypeTest.java index fbdf625..1e6eaf3 100644 --- a/sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/BeamComplexTypeTest.java +++ b/sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/BeamComplexTypeTest.java @@ -165,6 +165,19 @@ public class BeamComplexTypeTest { } @Test + public void testArrayConstructor() { + BeamSqlEnv sqlEnv = BeamSqlEnv.inMemory(readOnlyTableProvider); + PCollection<Row> stream = + BeamSqlRelUtils.toPCollection(pipeline, sqlEnv.parseQuery("SELECT ARRAY[1, 2, 3] f_arr")); + PAssert.that(stream) + .containsInAnyOrder( + Row.withSchema(Schema.builder().addArrayField("f_arr", FieldType.INT32).build()) + .addValue(Arrays.asList(1, 2, 3)) + .build()); + pipeline.run().waitUntilFinish(Duration.standardMinutes(2)); + } + + @Test public void testRowWithArray() { BeamSqlEnv sqlEnv = BeamSqlEnv.inMemory(readOnlyTableProvider); PCollection<Row> stream =