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