[jira] [Created] (FLINK-20202) Add the Check of Unsupported Result Type in Pandas UDAF

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-20202) Add the Check of Unsupported Result Type in Pandas UDAF

Shang Yuanchun (Jira)
Huang Xingbo created FLINK-20202:
------------------------------------

             Summary: Add the Check of Unsupported Result Type in Pandas UDAF
                 Key: FLINK-20202
                 URL: https://issues.apache.org/jira/browse/FLINK-20202
             Project: Flink
          Issue Type: Improvement
          Components: API / Python
            Reporter: Huang Xingbo
             Fix For: 1.12.0


Currently the return type of Pandas UDAF should be a primitive data type, and the returned scalar can be either a python primitive type, e.g., {{int}} or {{float}} or a numpy data type, e.g., {{numpy.int64}} or {{numpy.float64}}. {{Any}} should ideally be a specific scalar type accordingly. We will add related DataType check and throw a more readable exception for unsupported DataTypes. What's more, we will add related notes in docs.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)