日志
- 分享
mapreduce之-----HBASE大批量导入HDFS
-
2017-2-7 16:48
-
package com.cn.count; //com.cn.count.hbaseToHdfs import java.io.BufferedReader; import java.io.File; import java.io.FileInputStream; import java.io.FileWriter; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.text.DecimalFormat; impo ...
-
个人分类: HBASE|1050 次阅读|0 个评论
- 分享
mapreduce之-----HDFS大批量导入HBASE(map)
-
2017-2-7 16:46
-
/** * Copyright (c) 2017 21CN.COM . All rights reserved. * * Description: HBaseTo * * pre * Modified log: * ------------------------------------------------------ * Ver. Date Author Description * ------------------ ...
-
个人分类: HBASE|849 次阅读|0 个评论
- 分享
Mapreduce之计算取值读取多层路径
-
2017-1-17 14:58
-
代码：读取多层文件，有些文件可能为空，统计不为空文件中特定用户的个数 /** * Copyright (c) 2017 21CN.COM . All rights reserved. * * Description: HBaseTo * * pre * Modified log: * ------------------------------------------------------ ...
-
个人分类: mapreduce|1104 次阅读|0 个评论
热度 1
- 分享
json解析与反解析
-
2017-1-9 10:48
-
package aaa; import java.text.ParseException; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; import org.json.JSONArray; import org.json.JSONException; import org.json.JSONObject; public class json { /** & ...
-
个人分类: java|902 次阅读|0 个评论
- 分享
mapreduce之-----HBASE大批量导入HBASE(map)
-
2017-1-8 10:05
-
场景：读取hbase数据，做相关处理，再次写入到hbase中 命令： hadoop jar NdbgMR.jar com.cn.count.hbaseReMR 设置hbase基本属性： String tablename = "ndbgBil"; String targettablename = "ndbgBill"; Configuration conf = new Configuration(); ...
-
个人分类: HBASE|1114 次阅读|0 个评论
- 分享
mapreduce之-----HDFS大批量导入HBASE(map)
-
2017-1-8 09:51
-
场景：读取HDFS文件，做处理，写入HBASE 命令：hadoop jar NdbgMR.jar com.cn.count.HBaseMR 201602 /user/***/part-* package com.cn.count; /** * Copyright (c) 2016***. All rights reserved. * * Description: ndbgBill * * pre * Modified ...
-
个人分类: HBASE|875 次阅读|0 个评论
- 分享
mapredce之--------大批量HDFS的数据迁往HBASE（map+reduce）
-
2017-1-8 09:44
-
输入命令： hadoop jar NdbgMR.jar com.cn.count.HBaseMR 201602 /user/.../part-* 程序中args 代表年份 程序中args 代表所处理数据路径 给程序打jar包： Job job = new Job(conf, "ndbg_bill table"); job.setJarByClass(HBaseMR.class); ： 设置处理顺序： job.setMapperClass(Map. ...
-
个人分类: HBASE|493 次阅读|0 个评论
- 分享
java 数据类型转换
-
2016-12-8 11:53
-
String转换为float String str=""; float f=Float.valueof(str); float f=new Float(str); float f=Float.parseFloat(str); float转换为int float f=m; int in=m.intValue(); int in=(int)m;
-
个人分类: java|773 次阅读|0 个评论
热度 1
- 分享
网页爬取html页面简单爬取
-
2016-11-30 15:34
-
网页爬取html页面简单爬取 Connection connection= Jsoup.connect(""); Document document=connection.get(); Elements elements=document.getElementsByTag(""); String eString=elements.first().text(); JSONObject jsonObject=JSONObject.fromObject(eString); Ob ...
-
个人分类: 网页爬虫|650 次阅读|0 个评论
- 分享
Thread与Runnable的线程区别
-
2016-10-27 09:39
-
多线程Thread与runnable的区别： Thread只能通过单继承来实现：例如 class myThread extends Thread{ void run(){ } } myThread my=new myThread(); my.start(); runnable由于是接口而不是通过继承来实现：如下 class myThread implements Runnable{ void run(){ } } ...
-
个人分类: 线程|647 次阅读|0 个评论
- 新手帮助
- 新手帮助：注册遇到问题，领取资源，加入铁粉群，不会使用搜索，如何获取积分等
查看 »
/2 
