table.put(put); // put to server
}
}
public void get(String rowkey, String columnFamily, String column,
int versions) throws IOException {
long st = System.currentTimeMillis();
Get get = new Get(Bytes.toBytes(rowkey));
get.addColumn(Bytes.toBytes(columnFamily), Bytes.toBytes(column));
Scan scanner = new Scan(get);
scanner.setMaxVersions(versions);
ResultScanner rsScanner = table.getScanner(scanner);
for (Result result : rsScanner) {
final List<KeyValue> list = result.list();
for (final KeyValue kv : list) {
System.out.println(Bytes.toStringBinary(kv.getValue()) + "\t"
+ kv.getTimestamp()); // mid + time
}
}
rsScanner.close();
long en2 = System.currentTimeMillis();
System.out.println("Total Time: " + (en2 - st) + " ms");
}
}
在/usr/local/bigdatacase下新建hbase子目录,用来存放导出的ImportHBase.jar
打包成可执行jar包并导出至/usr/local/bigdatacase/hbase目录下
4.数据导入
在导入数据前,先把user_action表清空
运行hadoop jar命令来运行刚刚的jar包
5.查看HBase中user_action表数据
四、利用R进行数据可视化分析
1、安装R
用vim编辑器打开/etc/apt/sources.list文件
在文件的最后一行添加厦门大学的镜像源
保存文件退出vim编辑器,执行如下命令更新软件源列表
执行如下命令安装R语言
用vim编辑器打开/etc/apt/sources.list文件
在文件最后一行添加下列语句
保存文件退出vim编辑器,执行如下命令更新软件源列表
执行如下命令安装R语言
启动R
执行以下命令退出
2、安装依赖库
进入R命令模式,输入以下命令
出现以下错误信息
执行下列语句
再次执行RMySQL下载命令
执行如下命令安装绘图包ggplot2
运行以下命令安装devtools
安装相应的包
Install.packages(‘相应的依赖’)
再次尝试下载devtools,成功。
最后执行如下命令安装taiyun/recharts.
3、可视化分析
1、连接MySQL,并获取数据
新建终端,并启动mysql
进入mysql命令提示符状态
输入SQL语句查询数据
切换到R命令窗口,连接到MySQL数据库
2、分析消费者对商品的行为
使用summary()函数查看MySQL数据库表user_action的字段behavior_type的类型
看出user_action表中字段behavior_type的类型是字符型,这样不方便作比较,需要将其转换为数值型,命令与执行结果如下
用柱状图展示消费者的行为类型的行为类型分布情况
&nbs