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)