Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5015
---
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5015#discussion_r151851733
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/map.scala
---
@@ -0,0 +1,108 @@
+/*
+ * Licensed to the
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5015#discussion_r151851711
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/expressionDsl.scala
---
@@ -705,6 +705,14 @@ trait
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5015#discussion_r151401984
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/expressionDsl.scala
---
@@ -705,6 +705,14 @@ trait
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5015#discussion_r151408469
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/validate/FunctionCatalog.scala
---
@@ -333,6 +337,10 @@ class
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5015#discussion_r151409600
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/SqlExpressionTest.scala
---
@@ -156,6 +156,8 @@ class
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5015#discussion_r151408733
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/validate/FunctionCatalog.scala
---
@@ -333,6 +337,10 @@ class
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5015#discussion_r151407692
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/map.scala
---
@@ -0,0 +1,108 @@
+/*
+ * Licensed to the
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5015#discussion_r151408024
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/map.scala
---
@@ -0,0 +1,108 @@
+/*
+ * Licensed to the
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5015#discussion_r151406004
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/ExpressionParser.scala
---
@@ -141,6 +142,7 @@ object
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5015#discussion_r151406114
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/ExpressionParser.scala
---
@@ -141,6 +142,7 @@ object
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5015#discussion_r151407535
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/map.scala
---
@@ -0,0 +1,108 @@
+/*
+ * Licensed to the
GitHub user walterddr opened a pull request:
https://github.com/apache/flink/pull/5015
[FLINK-8038][Table API] Support MAP value constructor
## What is the purpose of the change
This pull request makes creates Map value constructor support for Table and
SQL API.
This
13 matches
Mail list logo