[jira] [Created] (FLINK-1076) Support function-level compatibility for Hadoop's wrappers functions

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-1076) Support function-level compatibility for Hadoop's wrappers functions

Shang Yuanchun (Jira)
Artem Tsikiridis created FLINK-1076:
---------------------------------------

             Summary:  Support function-level compatibility for  Hadoop's wrappers functions
                 Key: FLINK-1076
                 URL: https://issues.apache.org/jira/browse/FLINK-1076
             Project: Flink
          Issue Type: New Feature
          Components: Hadoop Compatibility
    Affects Versions: 0.7-incubating
            Reporter: Artem Tsikiridis


While the Flink wrappers for Hadoop Map and Reduce tasks are implemented in https://github.com/apache/incubator-flink/pull/37 it is currently not possible to use the {{ HadoopMapFunction }} and the {{ HadoopReduceFunction }} without a {{ JobConf }}. It woule be useful if we could specify a Hadoop Mapper, Reducer (or Combiner) and use them as seperate components in a Flink Job.



--
This message was sent by Atlassian JIRA
(v6.2#6252)