时间戳

首页 > 解决方案 > 如何在map-reduce的multipleinput中将虚拟变量设置为路径

java - 如何在map-reduce的multipleinput中将虚拟变量设置为路径

问题描述

我已将 hbase 表数据传递scan给映射器。有没有办法将虚拟路径或变量设置为路径参数MultipleInput()

List<Scan> scans = new ArrayList();
scans.add(data);

TableMapReduceUtils.initTableMapperJob(scans, Mapper.class, 
  ImmutalbeWriteable.class, ImmutalbeWriteable.class, job);

MultipleInputs.addInputPath(job, new Path("DUMMY"), 
  SequenceFileInputFormat.class, Mapper.class)

我收到错误：此路径不退出，同时DUMMY 在路径中传递变量，如下所示。

标签： javahadoopmapreducehdfshbase

解决方案

MultipleInputs.addInputPath(job, new Path("DUMMY"), 
  MultiTableInputFormat.class, Mapper.class)

推荐阅读