Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-14500

Support Flink Python User-Defined Stateless Function for Table - Phase 2

    XMLWordPrintableJSON

Details

    Description

      This is the umbrella Jira which tracks the functionalities of "Python User-Defined Stateless Function for Table" which are planned to be supported in 1.11, such as docker mode support, user-defined metrics support, arrow support, etc.

      Attachments

        Issue Links

          relates to

          New Feature - A new feature of the product, which has yet to be developed. FLINK-14013 Support Flink Python User-Defined Stateless Function for Table

          • Major - Major loss of function.
          • Closed
          1.
          		 Support to run the Python worker in docker mode Sub-task Open Unassigned  
          2.
          		 Support accessing job parameters in Python user-defined functions Sub-task Closed Dian Fu  
          3.
          		 Support use-defined metrics in Python user-defined functions Sub-task Closed Unassigned  
          4.
          		 User Apache Arrow as the serializer for data transmission between Java operator and Python harness Sub-task Closed Dian Fu  
          5.
          		 Optimize for Python UDFs with all parameters are constant values Sub-task Open Unassigned  
          6.
          		 Support to configure the log level of the Python user-defined functions Sub-task Open Unassigned  
          7.
          		 The close method does not work for Python UserDefinedFunction Sub-task Closed Dian Fu  
          8.
          		 Support python UDFs with constant value of time interval types Sub-task Open Unassigned  
          9.
          		 Add Python Table Function Runner And Operator Sub-task Closed Huang Xingbo
          10.
          		 Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction Sub-task Closed Huang Xingbo
          11.
          		 Add Python building blocks to make sure the basic functionality of Python TableFunction could work Sub-task Closed Huang Xingbo
          12.
          		 Add rules to push down the Java Calls contained in Python Correlate node Sub-task Closed Huang Xingbo
          13.
          		 Add rules to transpose the join condition of Python Correlate node Sub-task Closed Huang Xingbo
          14.
          		 Add Python UDTF doc Sub-task Closed Huang Xingbo
          15.
          		 Support Python UDTF in old planner under batch mode Sub-task Closed Unassigned
          16.
          		 Support Python UDTF in blink planner under batch mode Sub-task Closed Huang Xingbo  

          Activity

            People

              Unassigned Unassigned
              dian.fu Dian Fu
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:

                Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 2.5h
                  2.5h