[FLINK-7358] Add implicitly converts support for User-defined function

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Abandoned
• Component/s: Table SQL / API
• Labels: pull-request-available
• Assignee: sunjincheng
• Reporter: sunjincheng
• Created: 03/Aug/17 05:43
• Updated: 30/Jan/19 09:49
• Resolved: 30/Jan/19 09:49

Description

Currently if user defined a UDF as follows:

object Func extends ScalarFunction {
  def eval(a: Int, b: Long): String = {
    ...
  }
}

And if the table schema is (a: Int, b: int, c: String), then we can not call the UDF `Func('a, 'b)`. So
I want add implicitly converts when we call UDF. The implicitly convert rule is:

BYTE_TYPE_INFO -> SHORT_TYPE_INFO -> INT_TYPE_INFO -> LONG_TYPE_INFO -> FLOAT_TYPE_INFO -> DOUBLE_TYPE_INFO

*Note:
In this JIRA. only for TableAPI, And SQL will be fixed in https://issues.apache.org/jira/browse/CALCITE-1908.*

What do you think? fhueske

Issue Links

• links to: GitHub Pull Request #4534
• links to: GitHub Pull Request #4534