Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-3221 Move Table API on top of Apache Calcite
  3. FLINK-3227

Translate physical Table API plan into DataSet program

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Closed
    • Major
    • Resolution: Won't Fix
    • None
    • None
    • Table SQL / API
    • None

    Description

      The RelNode tree generated by FLINK-3226 is a 1-to-1 representation of the final DataSet API program. Hence, the translation step only needs to create corresponding operators with correct keys and user-functions. User-functions are implemented as RichFunctions that wrap generated code. In a first version, the wrapping functions are parameterized with a source code string which is generated during the program construction. As a first step, we can reuse much of the code generation logic of the current Table API.
      The source code string is compiled in the open() method of the wrapping function and later invoked by the wrapper.

      Attachments

        Issue Links

          depends upon

          New Feature - A new feature of the product, which has yet to be developed. FLINK-3282 Add FlinkRelNode interface.

          • Major - Major loss of function.
          • Closed

          Activity

            People

              twalthr Timo Walther
              fhueske Fabian Hueske
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: