You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/11/18 03:24:00 UTC

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

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)