说明:sql_runner是一个以Spark SQL为内核,以SQL为主体,扩展支持了数据质量拓扑,支持多种外部数据源,支持数据处理流程控制的数据处理引擎。
用户通过sql_runner命令就可以执行一个包含各种扩展SQL的sql任务。运行命令: sql_runner [job_file.sql]
快速开始
编写SQL文件:
/* ***********************************************
author: kun.wan
period: day
run
<weixin_42166623> 上传 | 大小:879kb