本文为您介绍如何在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操作,允许包含多个数据源和多个数据目标端。