本文为您介绍如何在Spark SQL流式处理中使用INSERT INTO语句。
语法
INSERT INTO tbName[(columnName[,columnName]*)]
queryStatement;
示例
INSERT INTO LargeOrders
SELECT * FROM Orders WHERE units > 1000;
说明
- 不支持单独的SELECT查询,必须有CTAS或者在
INSERT INTO ...
内才能操作。 - 单个作业支持在一个SQL文件里面包含多个DML操作,允许包含多个数据源和多个数据目标端。