You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by an...@apache.org on 2019/05/30 18:51:27 UTC
[beam] branch master updated: [SQL] Add array constructor test
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 =