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

Add a simplified UDF type extraction

Attach filesAttach ScreenshotAdd voteVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

    Details

    • Type: New Feature
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: Table SQL / API
    • Labels:
      None

      Description

      Currently, the input, accumulator, and output types of UDFs are partially defined within an UDF and outside of the UDF in language-specific table environments (Scala vs. Java). This makes UDFs environment-dependent and not modular. It also blocks the unified org.apache.flink.table.api.TableEnvironment.

      A better approach is to perform the type extraction Table API specific within the UDF and let users add additional information through UDF annotations.

      An exact annotation and extraction design will follow.

        Attachments

        Issue Links

          Activity

            People

            • Assignee:
              twalthr Timo Walther
              Reporter:
              twalthr Timo Walther

              Dates

              • Created:
                Updated:

                Time Tracking

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

                  Issue deployment