Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4726
---
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4726#discussion_r150540850
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/UserDefinedScalarFunctionTest.scala
---
@@ -89,6 +90,14 @@ class Use
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/4726#discussion_r150539995
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/table/CorrelateITCase.scala
---
@@ -210,6 +213,31 @@ class Correl
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/4726#discussion_r150539194
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/UserDefinedScalarFunctionTest.scala
---
@@ -89,6 +90,14 @@ class Use
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4726#discussion_r142237447
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/batch/table/CorrelateITCase.scala
---
@@ -22,7 +22,7 @@ import java.sql.
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4726#discussion_r142238899
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/UserDefinedScalarFunctionTest.scala
---
@@ -89,6 +90,14 @@ class Use
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4726#discussion_r142238516
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/table/CorrelateITCase.scala
---
@@ -210,6 +213,31 @@ class Correl
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/4726
[FLINK-7678] [table] Support composite inputs for user-defined functions
## What is the purpose of the change
This PR adds tests for rows as inputs for TableFunctions and
ScalarFunctions.
