问题描述
我已经使用scan
将hbase表数据传递给了映射器。有没有办法在Multipleinput()
List<Scan> scans = new ArrayList();
scans.add(data);
TableMapReduceUtils.initTableMapperJob(scans,Mapper.class,ImmutalbeWriteable.class,job);
MultipleInputs.addInputPath(job,new Path("DUMMY"),SequenceFileInputFormat.class,Mapper.class)
解决方法
MultipleInputs.addInputPath(job,new Path("DUMMY"),MultiTableInputFormat.class,Mapper.class)