clickhouse集成HDFS
·
1 使用的是集成引擎 HDFS
create table tb_hdfs(
uid Int32 ,
name String ,
gender String
)engine=HDFS('hdfs://doit01:8020/ch' , 'CSV') ;
insert into tb_hdfs values(1,'zss','M'),(2,'lss','F') ;

2 from
准备一个数据上传到HDFS中
1,URL1,2020-07-21,click
2,URL1,2020-07-21,show
3,URL1,2020-07-21,click
4,URL1,2020-07-21,click
5,URL1,2020-07-21,show
6,URL1,2020-07-21,click
7,URL1,2020-07-21,click
8,URL1,2020-07-21,show
9,URL1,2020-07-21,click
10,URL1,2020-07-21,click
hdfs dfs -put app.csv /doit/
和HDFS集成 直接读取(拉取) HDFS上的数据
SELECT
count(1),
event
FROM hdfs('hdfs://doit01:8020/doit/app.csv', 'CSV', 'id Int8,url String,ctime Date,event String')
GROUP BY event
create table tb_app_from_hdfs engine=TinyLog as
SELECT * FROM hdfs('hdfs://doit01:8020/doit/app.csv', 'CSV', 'id Int8,url String,ctime Date,event String');
更多推荐
所有评论(0)