You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2017/07/24 12:31:10 UTC
[2/2] flink git commit: [FLINK-7137] [table] Backport of tests for
Flink 1.3
[FLINK-7137] [table] Backport of tests for Flink 1.3
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8c87c446
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8c87c446
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/8c87c446
Branch: refs/heads/release-1.3
Commit: 8c87c44692bc27fb8018adf587715a9488947799
Parents: be8ca8a
Author: twalthr <tw...@apache.org>
Authored: Mon Jul 24 14:27:07 2017 +0200
Committer: twalthr <tw...@apache.org>
Committed: Mon Jul 24 14:27:07 2017 +0200
----------------------------------------------------------------------
.../table/expressions/ScalarOperatorsTest.scala | 17 +++++++++++++++--
1 file changed, 15 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/8c87c446/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/ScalarOperatorsTest.scala
----------------------------------------------------------------------
diff --git a/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/ScalarOperatorsTest.scala b/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/ScalarOperatorsTest.scala
index 0639835..5a82a8f 100644
--- a/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/ScalarOperatorsTest.scala
+++ b/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/ScalarOperatorsTest.scala
@@ -138,6 +138,17 @@ class ScalarOperatorsTest extends ExpressionTestBase {
@Test
def testOtherExpressions(): Unit = {
+
+ // nested field null type
+ testSqlApi("CASE WHEN f13.f1 IS NULL THEN 'a' ELSE 'b' END", "a")
+ testSqlApi("CASE WHEN f13.f1 IS NOT NULL THEN 'a' ELSE 'b' END", "b")
+ testAllApis('f13.isNull, "f13.isNull", "f13 IS NULL", "false")
+ testAllApis('f13.isNotNull, "f13.isNotNull", "f13 IS NOT NULL", "true")
+ testAllApis('f13.get("f0").isNull, "f13.get('f0').isNull", "f13.f0 IS NULL", "false")
+ testAllApis('f13.get("f0").isNotNull, "f13.get('f0').isNotNull", "f13.f0 IS NOT NULL", "true")
+ testAllApis('f13.get("f1").isNull, "f13.get('f1').isNull", "f13.f1 IS NULL", "true")
+ testAllApis('f13.get("f1").isNotNull, "f13.get('f1').isNotNull", "f13.f1 IS NOT NULL", "false")
+
// boolean literals
testAllApis(
true,
@@ -239,7 +250,7 @@ class ScalarOperatorsTest extends ExpressionTestBase {
// ----------------------------------------------------------------------------------------------
def testData = {
- val testData = new Row(13)
+ val testData = new Row(14)
testData.setField(0, 1: Byte)
testData.setField(1, 1: Short)
testData.setField(2, 1)
@@ -253,6 +264,7 @@ class ScalarOperatorsTest extends ExpressionTestBase {
testData.setField(10, "String")
testData.setField(11, false)
testData.setField(12, null)
+ testData.setField(13, Row.of("foo", null))
testData
}
@@ -270,7 +282,8 @@ class ScalarOperatorsTest extends ExpressionTestBase {
Types.INT,
Types.STRING,
Types.BOOLEAN,
- Types.BOOLEAN
+ Types.BOOLEAN,
+ Types.ROW(Types.STRING, Types.STRING)
).asInstanceOf[TypeInformation[Any]]
}