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)