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');

 

 

 

Logo

北京人形旗下天工造物具身智能开源社区,聚焦具身天工与慧思开物两大平台

更多推荐