Avro mapred and ChainMapper

["putra.manggala@gmail.com" <pu...@gmail.com>]

Hello,

My mapper has the following details:

public class M1 extends MapReduceBase
implements Mapper<AvroWrapper<Record1>, NullWritable,
AvroKey<Record2>, AvroValue<Record3>> {

where Record1, Record2 and Record3 implement IndexedRecord

To drive this, I'd like to use ChainMapper, but the following two
approaches don't compile:

(1)

JobConf conf = new JobConf(getConf(), MyJob.class);
JobConf conf2 = new JobConf(false);

ChainMapper.addMapper(conf,
					M1.class,
								new AvroWrapper<Record1>().getClass(),
								NullWritable.class,
								new AvroKey<Record2>().getClass(),
								new AvroValue<Record3>().getClass(),
								true, 				conf2);


(2)

JobConf conf = new JobConf(getConf(), MyJob.class);
JobConf conf2 = new JobConf(false);

ChainMapper.addMapper(conf,
					M1.class, AvroWrapper.class, NullWritable.class, AvroKey.class,
AvroValue.class,
true, conf2);

Does anybody have any idea?