大数据实行二
实行二：https://www.hifleet.com/wp/communities/data/hangyundashujujishukechengshiyanzhinan/paged/2#post-2295Cassandra and HBase
1.Cassandra
1.1java情况变量准备
NonSQL(not only sql),列式存储
首先是配备情况变量,创建CASSANDRA_HOME系统变量，并将该变量添加到情况变量，同时留意也要添加JAVA_HOME系统变量和JAVA_HOME情况变量（推荐下载JDK8）
https://i-blog.csdnimg.cn/direct/11c7c2f32b3c4f1fa6f733258a7f41ce.png
1.2cassandra启动
https://i-blog.csdnimg.cn/direct/a65fb9908a714aeeb39d78cc5fba3dd9.png
1.3Dbeaver图形化操作cassandra
找到cassandra目录下，下令行输入cassandra,打开端口，进入dbeaver举行毗连cassandra数据库
1.3.1 创建Keyspace和Column family（数据准备）
创建ais keyspace图
CREATE KEYSPACE ais WITH REPLICATION = { 'class' : 'org.apache.cassandra.locator.SimpleStrategy', 'replication_factor': '1' } AND DURABLE_WRITES = true;
创建ship_trajectory_data表
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数据导入
https://i-blog.csdnimg.cn/direct/84a56914f8b944faa7458a3385a282b0.png
下令行，把数据举行导入
sstableloader -d localhost "F:\cassandra2\apache-cassandra-2.1.12\data\data\ais\ship_trajectory_data-fc9dc350be0b11efa0d67fa2a1bbda3b"（自己的路径）
https://i-blog.csdnimg.cn/direct/b114c8bb87db46c7a41e3b6b55ee0b3f.png
在dbeaver输入以下代码块，可以看到导入信息
select * from ais.ship_trajectory_data;
https://i-blog.csdnimg.cn/direct/41efb7d1b19444978da4432fd7bf934e.png
手写类似sql语句举行插入
数据插入
insert into ais.ship_trajectory_data(ship_mmsi,update_time,data_value)
values (414726000,'2024-10-01 0800','this is data_value');
数据查询
select * from ais.ship_trajectory_data where ship_mmsi=414726000;
https://i-blog.csdnimg.cn/direct/8b755da36aac4f0989d24fe0384a96c5.png
2.HBase
2.1 HBase准备
2.1.1修改配置文件
https://i-blog.csdnimg.cn/direct/5c11c088821549d2a2a593cfd4347d68.png
<property>
<name>hbease.rootdir</name>
<value>F:/hbase/hbase-1.3.6/tmp/hbase/root</value>
</property>
<property>
<name>hbase.tmp.dir</name>
<value>F:/hbase/hbase-1.3.6/tmp/hbase/tmp</value>
</property>
<property>
<name>hbase.zookeeper.quorum</name>
<value>localhost</value>
</property>
<property>
<name>hbase.zookeeper.property.clientPort</name>
<value>2181</value>
</property>
<property>
<name>hbase.zookeeper.property.dataDir</name>
<value>F:/hbase/hbase-1.3.6/tmp/hbase/zoo</value>
</property>
<property>
<name>hbase.cluster.distributed</name>
<value>false</value>
</property>
<property>
<name>hbase.master.info.port</name>
<value>60010</value>
</property>
<property>
<name>dfs.permissions.enabled</name>
<value>false</value>
</property>
对应hbase路径F:/hbase/hbase-1.3.6举行自行修改
2.2 Hbase启动
找到F:\hbase\hbase-1.3.6\bin路径（自己安装的路径下的bin）
https://i-blog.csdnimg.cn/direct/8857d2e8470343eeb5c0822fa39a8538.png
通过以下下令举行hbase的启动
start-hbase.cmd
https://i-blog.csdnimg.cn/direct/e4ba519997c244a39290cb0dab64bc8a.png
如果出现这个错误
https://i-blog.csdnimg.cn/direct/9880a098f4ff40d9981c83db54cd0dbd.png
就必须把实行二https://www.hifleet.com/wp/communities/data/hangyundashujujishukechengshiyanzhinan/paged/2#post-2295中的winutils.exe 和 hadoop.dll 两个文件，拷贝到c:/windows/system32 目录下
https://i-blog.csdnimg.cn/direct/bb8aba1812ae4596958e8245ba470062.png
2.3 Hbase监控
欣赏器打开http://localhost:60010
https://i-blog.csdnimg.cn/direct/3c2f28e3be1a40d7a434fd5e52c03bac.png
2.4 Hbase使用
2.4.1shell登入HBase
hbase shell
https://i-blog.csdnimg.cn/direct/0180e65265a744c68947ec5c90458e28.png
2.4.2 hbase创建数据表
create 'dynamic_ships',{NAME => 'fields_family', COMPRESSION => 'GZ'}
该下令将在HBase中新建一个名为“dynamic_ships” 的数据表，该数据表有一个名为“fields_family” 列族，在该列族下可以创建多个列。
使用list下令检察有哪些表，使用== describe== 下令，可以检察数据表的布局和其他相干参数
https://i-blog.csdnimg.cn/direct/bec792c775214cf7a060b00f21d32b8c.png
2.4.3 hbase数据表中写数据
put 'dynamic_ships','414726000-1567325862','fields_family:t','2019-09-01 1642'
put 'dynamic_ships','414726000-1567325862','fields_family:lon',120.41596
put 'dynamic_ships','414726000-1567325862','fields_family:lat',32.042835
put 'dynamic_ships','414726000-1567325862','fields_family:course',234.2
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'
检察修改后的值。
https://i-blog.csdnimg.cn/direct/4ab0c8ba272b4196bbe700650af1a763.png
使用scan下令来扫描
scan 'dynamic_ships'
https://i-blog.csdnimg.cn/direct/c5af9dfb615c40259576cb83e51d45ff.png
获取行值为414726000-1567325862相干表信息
get 'dynamic_ships','414726000-1567325862'
获取行名为414726000-1567325862，列名为列族fields_family中的t列
2.4.5 hbase数据表删除数据
get 'dynamic_ships','414726000-1567325862'
,'fields_family:t' 删除行名为414726000-1567325862,列名为列族fields_family中的speed列
delete 'dynamic_ships','414726000-1567325862','fields_family:speed'
删除整个数据表
disable 'dynamic_ships'
drop 'dynamic_ships'
2.5 Hbase关闭
先退出shell，通过
exit()
然后再关闭
stop-hbase.cmd
https://i-blog.csdnimg.cn/direct/713e40dfa22d4c7082f92c98ff0fcf96.png
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。
页:
[1]