sql_runner是一个以Spark SQL为内核,以SQL为主体,扩展支持了数据质量拓扑,支持多种外部数据源,支持数据处理流程控制的数据处理引擎。 用户通过sql_runner命令就可以执行一个包含各种扩展SQL的sql任务。运行命令: sql_runner [job_file.sql] 快速开始 编写SQL文件: /* *********************************************** author: kun.wan period: day run_env: PRD describe: 基础数据处理脚本 *********************************************** */ INSERT OVERWRITE TABLE trade . dws_trade partition(dt = ' ${date|yy