Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-19185 Support General Python User-Defined Aggregate Function Support on Table API (FLIP-139)
  3. FLINK-19236

Optimize the performance of Python UDAF

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Closed
    • Major
    • Resolution: Implemented
    • None
    • 1.13.0
    • API / Python
    • None

    Attachments

      Issue Links

        is a parent of

        Improvement - An improvement or enhancement to an existing feature or task. FLINK-20639 Use list to optimize the Row used by Python UDAF intermediate results

        • Major - Major loss of function.
        • Closed

        Improvement - An improvement or enhancement to an existing feature or task. FLINK-20640 Use cython to optimize the logic of computing in Python UDAF

        • Major - Major loss of function.
        • Closed

        Improvement - An improvement or enhancement to an existing feature or task. FLINK-20642 Introduce InternalRow to optimize Row used in Python UDAF

        • Major - Major loss of function.
        • Closed

        Improvement - An improvement or enhancement to an existing feature or task. FLINK-20769 Support minibatch to optimize Python UDAF

        • Major - Major loss of function.
        • Closed

        Activity

          People

            hxbks2ks Huang Xingbo
            zhongwei Wei Zhong
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: