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

Posted to issues@flink.apache.org by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/17 07:26:00 UTC

[jira] [Created] (FLINK-20642) Introduce InternalRow to optimize Row used in Python UDAF

Huang Xingbo created FLINK-20642:
------------------------------------

             Summary: Introduce InternalRow to optimize Row used in Python UDAF
                 Key: FLINK-20642
                 URL: https://issues.apache.org/jira/browse/FLINK-20642
             Project: Flink
          Issue Type: Improvement
            Reporter: Huang Xingbo


InternalRow is a cython class
{code:java}
cdef enum InternalRowKind:
    INSERT = 0
    UPDATE_BEFORE = 1
    UPDATE_AFTER = 2
    DELETE = 3

cdef class InternalRow:
    cdef list values
    cdef InternalRowKind row_kind{code}



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