Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-14013 Support Flink Python User-Defined Stateless Function for Table
  3. FLINK-14015

Introduce PythonScalarFunctionOperator as a standalone StreamOperator for Python ScalarFunction execution

    XMLWordPrintableJSON

    Details

      Description

      PythonScalarFunctionOperator is a standalone StreamOperator and it doesn’t need to how the Python ScalarFunctions are executed which is the responsibility of PythonScalarFunctionRunner:

      1. It is a StreamOperator which employs PythonScalarFunctionRunner for Python ScalarFunction execution
      2. It sends input elements to PythonScalarFunctionRunner, fetches the execution results, constructs the result rows and sends them to the downstream operator
      3. It should handle the checkpoint and watermark properly

        Attachments

          Issue Links

            Activity

              People

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

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

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