Hi,

I've searched but didn't find any answers, so decided to post to this list.
I'm trying to convert MultipleInputs into oozie <map-reduce> action.
My perfectly working code in main() is:
MultipleInputs.addInputPath(conf, new Path(inFirm), SequenceFileInputFormat.class, FirmMapper.class); MultipleInputs.addInputPath(conf, new Path(inOffice), SequenceFileInputFormat.class, OfficeMapper.class);
        FileOutputFormat.setOutputPath(conf, new Path(mr1Out));
        conf.setOutputFormat(SequenceFileOutputFormat.class);
        conf.setMapOutputKeyClass(TextPair.class);
        conf.setMapOutputValueClass(Text.class);
        conf.setPartitionerClass(TextPair.FirstPartitioner.class);
conf.setOutputValueGroupingComparator(TextPair.FirstComparator.class);
        conf.setReducerClass(SingleOfficeFirmReducer.class);
        conf.setOutputKeyClass(TextPair.class);
        conf.setOutputValueClass(Text.class);
How do I translate MultipleInputs and multiple mappers into oozie workflow?
All the examples show only the single mapper.

br,
Tom

Reply via email to