You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Artem Tsikiridis (JIRA)" <ji...@apache.org> on 2014/08/28 19:32:08 UTC

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

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)