大数据实行二

实行二：https://www.hifleet.com/wp/communities/data/hangyundashujujishukechengshiyanzhinan/paged/2#post-2295
Cassandra and HBase

1.Cassandra

1.1java情况变量准备

NonSQL(not only sql),列式存储
首先是配备情况变量,创建CASSANDRA_HOME系统变量，并将该变量添加到情况变量，同时留意也要添加JAVA_HOME系统变量和JAVA_HOME情况变量（推荐下载JDK8）

1.2cassandra启动

1.3Dbeaver图形化操作cassandra

找到cassandra目录下，下令行输入cassandra,打开端口，进入dbeaver举行毗连cassandra数据库
1.3.1 创建Keyspace和Column family（数据准备）

创建ais keyspace图

1. CREATE KEYSPACE ais WITH REPLICATION = { 'class' : 'org.apache.cassandra.locator.SimpleStrategy', 'replication_factor': '1' } AND DURABLE_WRITES = true;

复制代码

创建ship_trajectory_data表

1. CREATE TABLE ais.ship_trajectory_data ( ship_mmsi int, update_time text, data_value text, PRIMARY KEY (ship_mmsi, update_time) );

复制代码

1.3.2 sstableloader数据导入

下令行，把数据举行导入

1. sstableloader -d localhost "F:\cassandra2\apache-cassandra-2.1.12\data\data\ais\ship_trajectory_data-fc9dc350be0b11efa0d67fa2a1bbda3b"（自己的路径）

复制代码

在dbeaver输入以下代码块，可以看到导入信息

1. select * from ais.ship_trajectory_data;

复制代码

手写类似sql语句举行插入
数据插入

1. insert into ais.ship_trajectory_data(ship_mmsi,update_time,data_value)
2. values (414726000,'2024-10-01 0800','this is data_value');

复制代码

数据查询

1. select * from ais.ship_trajectory_data where ship_mmsi=414726000;

复制代码

2.HBase

2.1 HBase准备

2.1.1修改配置文件

1. <property>  
2.         <name>hbease.rootdir</name>  
3.         <value>F:/hbase/hbase-1.3.6/tmp/hbase/root</value>
4. </property>  
5. <property>  
6.         <name>hbase.tmp.dir</name>  
7.         <value>F:/hbase/hbase-1.3.6/tmp/hbase/tmp</value>  
8. </property>  
9. <property>  
10.         <name>hbase.zookeeper.quorum</name>  
11.         <value>localhost</value>
12. </property>  
13. <property>  
14.         <name>hbase.zookeeper.property.clientPort</name>  
15.         <value>2181</value>
16. </property>  
17. <property>  
18.         <name>hbase.zookeeper.property.dataDir</name>  
19.         <value>F:/hbase/hbase-1.3.6/tmp/hbase/zoo</value>  
20. </property>  
21. <property>  
22.         <name>hbase.cluster.distributed</name>  
23.         <value>false</value>  
24. </property>
25. <property>
26.         <name>hbase.master.info.port</name>
27.         <value>60010</value>
28. </property>
29. <property>
30.         <name>dfs.permissions.enabled</name>
31.         <value>false</value>
32. </property>

复制代码

对应hbase路径F:/hbase/hbase-1.3.6举行自行修改
2.2 Hbase启动

找到F:\hbase\hbase-1.3.6\bin路径（自己安装的路径下的bin）

通过以下下令举行hbase的启动

1. start-hbase.cmd

复制代码

如果出现这个错误

就必须把实行二https://www.hifleet.com/wp/communities/data/hangyundashujujishukechengshiyanzhinan/paged/2#post-2295中的winutils.exe 和 hadoop.dll 两个文件，拷贝到c:/windows/system32 目录下

2.3 Hbase监控

欣赏器打开http://localhost:60010

2.4 Hbase使用

2.4.1shell登入HBase

1. hbase shell

复制代码

2.4.2 hbase创建数据表

1. create 'dynamic_ships',{NAME => 'fields_family', COMPRESSION => 'GZ'}

复制代码

该下令将在HBase中新建一个名为“dynamic_ships” 的数据表，该数据表有一个名为“fields_family” 列族，在该列族下可以创建多个列。
使用list下令检察有哪些表，使用== describe== 下令，可以检察数据表的布局和其他相干参数

2.4.3 hbase数据表中写数据

1. put 'dynamic_ships','414726000-1567325862','fields_family:t','2019-09-01 1642'
2. put 'dynamic_ships','414726000-1567325862','fields_family:lon',120.41596
3. put 'dynamic_ships','414726000-1567325862','fields_family:lat',32.042835
4. put 'dynamic_ships','414726000-1567325862','fields_family:course',234.2
5. put 'dynamic_ships','414726000-1567325862','fields_family:speed',7.8

复制代码

上述四条下令，分别表示向上一步创建的数据表“dynamic_ships”，新建一个==rowkey为“414726000-1567325862”==的一条数据，为该条数据在其 ==“fields_family” ==列族里，分别创建5个列：t，lon，lat，course，speed，并且分别为这5个列赋值：‘2019-09-01 1642’，120.41596，32.042835，234.2，7.8
2.4.4 hbase数据表读数据

可以使用可以使用：
get 'dynamic_ships','414726000-1567325862'
,'fields_family:lon'
检察修改后的值。

使用scan下令来扫描

1. scan 'dynamic_ships'

复制代码

获取行值为414726000-1567325862相干表信息

1. get 'dynamic_ships','414726000-1567325862'

复制代码

获取行名为414726000-1567325862，列名为列族fields_family中的t列
2.4.5 hbase数据表删除数据

1. get 'dynamic_ships','414726000-1567325862'
2. ,'fields_family:t'

复制代码

删除行名为414726000-1567325862,列名为列族fields_family中的speed列

1. delete 'dynamic_ships','414726000-1567325862','fields_family:speed'

复制代码

删除整个数据表

1. disable 'dynamic_ships'
2. drop 'dynamic_ships'

复制代码

2.5 Hbase关闭

先退出shell，通过

1. exit()

复制代码

然后再关闭

1. stop-hbase.cmd

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。