Fabian Hueske created FLINK-3227:
------------------------------------

             Summary: Translate physical Table API plan into DataSet program
                 Key: FLINK-3227
                 URL: https://issues.apache.org/jira/browse/FLINK-3227
             Project: Flink
          Issue Type: Sub-task
          Components: Table API
            Reporter: Fabian Hueske


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.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to