【文件属性】:
文件名称:sql-runner
文件大小:879KB
文件格式:ZIP
更新时间:2021-03-10 14:37:45
Scala
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