谁用mapreduce往hbase中导入*.csv文件的_百度知道
谁用mapreduce往hbase中导入*.csv文件的
我有更好的答案
public static void main(String[] args) throws Exception {final Configuration configuration = new Configuration();
//设置zookeeper
configuration.set(&hbase.zookeeper.quorum&, &hadoop&);
//设置hbase表名称
configuration.set(TableOutputFormat.OUTPUT_TABLE, &wlan_log&);
//将该值改大，防止hbase超时退出
configuration.set(&dfs.socket.timeout&, &180000&);
final Job job = new Job(configuration, &HBaseBatchImport&);
job.setMapperClass(BatchImportMapper.class);
job.setReducerClass(BatchImportReducer.class);
//设置map的输出，不设置reduce的输出类型
job.setMapOutputKeyClass(LongWritable.class);
job.setMapOutputValueClass(Text.class);
job.setInputFormatClass(TextInputFormat.class);
//不再设置输出路径，而是设置输出格式类型
job.setOutputFormatClass(TableOutputFormat.class);
FileInputFormat.setInputPaths(job, &hdfs://hadoop:9000/input&);
job.waitForCompletion(true);
采纳率：90%
来自团队：
为您推荐：
其他类似问题
换一换
回答问题，赢新手礼包
个人、企业类
违法有害信息,请在下方选择后提交
色情、暴力
我们会通过消息、邮箱等方式尽快将举报结果通知您。没有更多推荐了，
不良信息举报
举报内容：
phoenix 把CSV格式的数据导入到Hbase执行日志
举报原因：
原文地址：
原因补充：
最多只允许输入30个字
加入CSDN，享受更精准的内容推荐，与500万程序员共同成长！没有更多推荐了，
不良信息举报
举报内容：
HBase 0.96.0 的数据导入: 利用ImportTsv，completebulkload，Import
举报原因：
原文地址：
原因补充：
最多只允许输入30个字
加入CSDN，享受更精准的内容推荐，与500万程序员共同成长！没有更多推荐了，
不良信息举报
举报内容：
将HDFS中的数据通过MapReduce产生HFile，然后将HFile导入到HBase具体案例分析
举报原因：
原文地址：
原因补充：
最多只允许输入30个字
加入CSDN，享受更精准的内容推荐，与500万程序员共同成长！}