Posts

首先应确定master和slave上都安装了Flume，如果slave上没有，可以将master上的传过去 scp -r /opt/flume/ root@slave1:/opt/ 配置一级Flume 在master上创建netcat-avro.conf，意思是一级flume从444端口收集信息，再从555端口以avro格式发到二级flume cd /opt/flume/conf vi netcat-avro.conf => a1.sources = r1 a1.channels = c1 a1.sinks = k1 a1.sources.r1.type = netcat a1.sources.r1.bind = master a1.sources.r1.port = 444 a1.sinks.k1.type = avro a1.sinks.k1.channel = c1 a1.sinks.k1.hostname=slave1 a1.sinks.k1.port = 555 a1.channels.c1.type = memory a1.channels.c1.capacity = 100 a1.channels.c1.transactionCapacity = 100 a1.sources.r1.channels = c1 a1.sinks.k1.channel = c1 <= 配置二级Flume 在slave上创建avro-logger.conf，意思是二级flume从555端口收集信息 cd /opt/flume/conf vi avro-logger.conf => a1.sources = r1 a1....

Flume用于收集、聚合和传输大量数据，如日志文件、事件等。 下载Flume安装包到master节点 wget --no-check-certificate https://od.fifcom.cn/misc/hadoop/apache-flume-1.8.0-bin.tar.gz 安装Flume 解压Flume tar -zxvf apache-flume-1.8.0-bin.tar.gz -C /opt/ mv /opt/apache-flume-1.8.0-bin/ /opt/flume/ 进入Flume的配置文件目录，并从模板复制配置文件 cd /opt/flume/conf cp flume-env.sh.template flume-env.sh 编辑环境配置文件中的JAVA_HOME vi flume-env.sh => export JAVA_HOME=/opt/jdk8u282-b08 <= 在当前目录创建netcat-logger.conf文件，用于配置一个简单的数据采集方案 vi netcat-logger.conf => a1.sources = r1 a1.sinks = k1 a1.channels = c1 a1.sources.r1.type = netcat a1.sources.r1.bind = master a1.sources.r1.port = 444 a1.sinks.k1.type = logger a1.channels.c1.type = memory a1.channels.c1.capacity = 1000 a1.channels.c1.transactionCapacity = 100 a1.sources.r1.channels = c1 a1.sinks.k1.channel = c1 <= 测试Flume 首先回到Flume根目录，并使用命令启用Flume...

Hive默认不支持数据的修改和删除，需编辑配置文件hive-site.xml以允许 <property> <name>hive.support.concurrency</name> <value>true</value> </property> <property> <name>hive.enforce.bucketing</name> <value>true</value> </property> <property> <name>hive.exec.dynamic.partition.mode</name> <value>nonstrict</value> </property> <property> <name>hive.txn.manager</name> <value>org.apache.hadoop.hive.ql.lockmgr.DbTxnManager</value> </property> <property> <name>hive.compactor.initiator.on</name> <value>true</value> </property> <property> <name>hive.compactor.worker.threads</name> <value>1</value> </property> 并配置thrift的账号(root)密码(root) <property> <name>hive.server2.thrift.client.user</name> <value>root</value> </property> <property> <name>hive.server2.thrift.client.password</name> <value>root</value> </property> <property> <name>hive.server2.authentication</name> <value>NONE</value> </property> 环境准备 启动Hadoop ./opt/hadoop/sbin/start-all.sh 启动HiveServer2 cd /opt/hive/bin/ ./hive --service hiveserver2 & 连接到HiveServer2 创建一个Maven项目，添加依赖项目...

Hive中内置了许多常用函数，此外，用户也可以自行编写函数 内置函数 查看系统自带函数 show functions; 显示自带函数的用法与描述 desc function upper; # 查看描述 desc function extended upper; # 查看描述+查看示例 自定义函数 UDF 总体编程步骤： 创建maven项目 导入hive-exec和hadoop-client，并使用spring的镜像源 继承org.apache.hadoop.hive.ql.UDF 实现evaluate()，必须有返回值，如果实在没有，返回null。 导出项目为jar文件 将jar文件导入Hive 创建Hive UDF（临时或永久） 创建Maven项目 首先需要在自己的机器上安装Maven，可以参考这里，并配置环境变量。配置好后可以在终端中测试:mvn -version 接着在idea中新建项目，设置构建系统为Maven，JDK为1.8 项目的文件结构像这样: HiveUDF/ src/ main/ java/ resources/ test/ java/ pom.xml 导入依赖 pom.xml包含了项目的基本信息, 编辑它 在project标签中添加依赖 <dependencies> <dependency> <groupId>org.apache.hadoop</groupId> <artifactId>hadoop-client</artifactId> <version>2.9.2</version> <!...

student表 id name 1 zhangsan 2 lisi 3 wangwu teacher表 id name 1 teacher_zhaoliu 2 teacher_wangqi 基本查询 全表查询 select * from student; select * from teacher; 特定列查询 select id from student; select name from teacher; 列别名 select id as a, name as b from student; 算数运算符：可以对结果集合进行算数运算以及位运算...

分桶针对数据文件进行分解，分解成更容易管理的多个部分(细粒度)。好处有： 方便抽样：分桶后可以很方便的在数据集的一小部分上查询。 提高join查询效率 分桶是在表或者分区表的基础上进一步对表进行组织，分桶会对列值进行Hash，来决定放在哪个桶中。保证每个桶中都有数据，但桶中的数据条数不一定相等。 创建分桶表 使用clustered by 命令指定划分桶的列，使用into N buckets指定桶的个数 create table buck (id int, name string) clustered by(id) into 4 buckets row format delimited fields terminated by '\t'; 可以看到桶个数(Num Buckets)为4 分桶表不能直接导入数据，需使用中间表。这里创建中间表 create table tmp (id int, name string) row format delimited fields terminated by '\t'; 导入数据 首先设置Hive参数 set hive.strict.checks.bucketing=false; 在本地/root/buck.txt中有 1\taaa 2\tbbb 3\tccc 4\tddd 由于不能直接导入分桶表，所以首先应导入普通表 load data local inpath '/root/buck.txt' into table tmp; 接着清空分桶表中的数据 truncate table buck; 最后插入tmp中的数据到分桶表中...

Hive中的分区就是子目录(粗粒度)，每个子目录包含了分区对应的列名和每一列的值，把大的数据集分割成小数据集。 分区表对应HDFS中的一个独立文件夹，该文件夹下存储了当前分区的所有数据文件。 在查询时使用where来指定分区，可提高查询效率。 创建分区表 使用partitioned bt 创建分区表，并使用dt作为分割分区的列名。 分割分区的列名越多分区的级数就越多，比如一个为一级分区，两个为二级分区。 use curd; create table part(id int, name string) partitioned by(dt date comment "partition field day time") row format delimited fields terminated by '\t'; 添加分区 给分区表添加分区，区分 分区的列名为dt alter table part add partition(dt="2022-05-01"); alter table part add partition(dt="2022-05-02"); alter table part add partition(dt="2022-05-03"); # 或者alter table part add partition(dt="2022-05-01") partition(dt="2022-05-02"); show partitions part; # 查看分区 导入数据 向分区中导入数据 在本地/root/中有三个文件: log01.txt，log02.txt，log03.txt 1\tzhangsan 2\tlisi 3\twangwu 4\tzhaoliu 导入数据:...

需启动Hadoop cd /opt/hadoop/sbin ./start-all.sh 并进入Hive命令行 cd /opt/hive/bin ./hive 创建数据库 create database curd; # create database if not exists curd; show databases; # desc database extended curd; # 可以查看数据库的详细信息 创建表后Hive默认会在HDFS的warehouse文件夹中创建文件夹curd.db/，将来可以直接拷贝数据文件到该目录下的相关表进行数据填充。 查看HDFS hdfs dfs -ls -R /user/hive/ 显示数据库 使用命令查看所有数据库 show databases; 查看数据库的描述与详细(extended)描述 desc database curd; # 查看描述 desc database extended curd; # 查看详细描述 修改数据库描述 数据库的名称和所在位置等不可修改，但可以添加/修改描述数据库的键值对。 alter database curd set dbproperties('createtime'='20220501'); 删除数据库 删除数据库前最好判断该数据库是否存在 drop database if exists curd; 数据库不为空时需要强制删除：使用cascade命令 drop database curd cascade; 创建内部表 内部表又称管理表...

安装Hive Hive是一个数据仓库，适合存读多写少的数据，依赖Hadoop。 下载安装包 wget --no-check-certificate https://od.fifcom.cn/misc/hadoop/apache-hive-2.3.9-bin.tar.gz wget --no-check-certificate https://od.fifcom.cn/misc/hadoop/mysql57-community-release-el7-10.noarch.rpm wget --no-check-certificate https://od.fifcom.cn/misc/hadoop/mysql-connector-java-5.1.49.tar.gz 安装配置元数据库 Hive需要配置元数据库，这里使用MySQL作为元数据库。 yum -y install mysql57-community-release-el7-10.noarch.rpm --nogpgcheck yum -y install mysql-community-server --nogpgcheck 查看MySQL状态, 此时为未启动(inactive) service mysqld status 启动MySQL systemctl start mysqld MySQL安装后会设置一个随机密码，可以通过log来查看 cat /var/log/mysqld.log | grep password 现在就可以登录MySQL的命令行了。 mysql -u root -p08d*****X49q 登录后修改root密码和设置可远程登录 # 修改root密码为H1ghEntr0pyPwd! alter user 'root'@'localhost' identified by 'H1ghEntr0pyPwd!'; # 设置可远程登录 grant all privileges on *.* to 'root'@'%' identified by 'H1ghEntr0pyPwd!' with grant option; # 刷新 flush privileges; 开启3306防火墙(如果之前没禁用防火墙的话)...

Phoenix JavaAPI可以在java中使用sql对HBase进行操作 配置项目环境 下载master节点中phoenix安装目录下的两个包到本地项目/phoenix中 phoenix-5.0.0-HBase-2.0-client.jar phoenix-core-5.0.0-HBase-2.0.jar 将这两个文件添加进模块依赖中 尝试建表代码，注意: JRE版本建议为1.8 建表 建表语法为 create table tablename(column1,column2,column3)，使用stmt.execute()执行 package demo; import java.sql.*; class PhoenixAPI { Connection conn = null; Statement stmt = null; PhoenixAPI() { try { Class.forName("org.apache.phoenix.jdbc.PhoenixDriver"); conn = DriverManager.getConnection("jdbc:phoenix:master:2181/hbase","",""); stmt = conn.createStatement(); } catch (ClassNotFoundException | SQLException e) { e.printStackTrace(); } } public void create(String tb) { // 注意：在Phoenix中，整数不能简写为int，而是要写为INTEGER String sql = "create table " + tb + " (id integer primary key, name varchar, age integer)"; try { stmt....