[EMAIL PROTECTED] wrote:
We decided that it is impossible in hadoop to have different input/output
types for map and reduce. Then we decided to use another scheme. This scheme
assumes to run two jobs. First job has map function, second job has reduce
task. These jobs have different classes for input and output parameters. New
map and reduce will do the same as described above.

You can use ObjectWritable to pass any type of Writable inside it. This way you can mix/match different input/output types easily. The overhead of this wrapping is probably still smaller than submitting another job just to change the types...

Please take a look at Indexer.java, where this trick is used.

--
Best regards,
Andrzej Bialecki     <><
___. ___ ___ ___ _ _   __________________________________
[__ || __|__/|__||\/|  Information Retrieval, Semantic Web
___|||__||  \|  ||  |  Embedded Unix, System Integration
http://www.sigram.com  Contact: info at sigram dot com


Reply via email to