实验二:https://www.hifleet.com/wp/communities/data/hangyundashujujishukechengshiyanzhinan/paged/2#post-2295
大数据实验二-Cassandra and HBase
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图
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数据导入
命令行,把数据进行导入
sstableloader -d localhost "F:\cassandra2\apache-cassandra-2.1.12\data\data\ais\ship_trajectory_data-fc9dc350be0b11efa0d67fa2a1bbda3b"(自己的路径)
在dbeaver输入以下代码块,可以看到导入信息
select * from ais.ship_trajectory_data;
手写类似sql语句进行插入
数据插入
insert into ais.ship_trajectory_data(ship_mmsi,update_time,data_value)
values (414726000,'2024-10-01 0800',<