|
|
|
FLINK-17423
|
FLINK-14500
Support Python UDTF in blink planner under batch mode
|
Huang Xingbo
|
Huang Xingbo
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-17013
|
FLINK-14500
Support Python UDTF in old planner under batch mode
|
Unassigned
|
Huang Xingbo
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-16748
|
FLINK-14500
Add Python UDTF doc
|
Huang Xingbo
|
Huang Xingbo
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-16008
|
FLINK-14500
Add rules to transpose the join condition of Python Correlate node
|
Huang Xingbo
|
Huang Xingbo
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-16007
|
FLINK-14500
Add rules to push down the Java Calls contained in Python Correlate node
|
Huang Xingbo
|
Huang Xingbo
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-15972
|
FLINK-14500
Add Python building blocks to make sure the basic functionality of Python TableFunction could work
|
Huang Xingbo
|
Huang Xingbo
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-15961
|
FLINK-14500
Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction
|
Huang Xingbo
|
Huang Xingbo
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-15913
|
FLINK-14500
Add Python Table Function Runner And Operator
|
Huang Xingbo
|
Huang Xingbo
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-14383
|
FLINK-14500
Support python UDFs with constant value of time interval types
|
Unassigned
|
Hequn Cheng
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
FLINK-14269
|
FLINK-14500
The close method does not work for Python UserDefinedFunction
|
Dian Fu
|
Dian Fu
|
|
Closed |
Invalid
|
|
|
|
|
|
|
|
FLINK-14222
|
FLINK-14500
Optimize for Python UDFs with all parameters are constant values
|
Unassigned
|
Dian Fu
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
FLINK-14028
|
FLINK-14500
Support to configure the log level of the Python user-defined functions
|
Unassigned
|
Dian Fu
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
FLINK-14025
|
FLINK-14500
Support to run the Python worker in docker mode
|
Unassigned
|
Dian Fu
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
FLINK-14024
|
FLINK-14500
Support use-defined metrics in Python user-defined functions
|
Unassigned
|
Dian Fu
|
|
Closed |
Duplicate
|
|
|
|
|
|
|
|
FLINK-14023
|
FLINK-14500
Support accessing job parameters in Python user-defined functions
|
Dian Fu
|
Dian Fu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-14020
|
FLINK-14500
User Apache Arrow as the serializer for data transmission between Java operator and Python harness
|
Dian Fu
|
Dian Fu
|
|
Closed |
Invalid
|
|
|
|
|