✨打造一套特定的类SQL语言,通过Antlr解析,自定义生成特定的分析代码(Flink/Spark/ML.....)。🕸️
### 1、使用什么解释器
use interpreter spark;
### 2、创建数据源
creat table table_name (
xxx int,
xxx string,
) with (
'connector' = 'hive',
xxx = xxx
);
### 3、特征工程
transform into table_name_b
select xxxx,COUNT(*) as bbb from table_name_a where xxx = xxx;
### 4、创建模型(待补充antlr)
create or replace model model_name
options(xxx=xxx) as ....;
### 5、使用模型进行预测(待补充antlr)
predict into table_name_c
select a,b,c from ml.predict(model `model_name`,select d,e,f from t1);
### 6、保存数据
INSERT { INTO | OVERWRITE } [catalog_name.][db_name.]table_name [PARTITION part_spec] [column_list]
select_statement
### (待定)是否需要一个查看语句?例如:
show select xxxx,COUNT(*) as bbb from table_name_a where xxx = xxx;