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

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

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

Shang Yuanchun (Jira)
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)