E-MapReduce INSERT INTO

By | 2021年4月23日

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

请关注公众号获取更多资料

发表回复

您的电子邮箱地址不会被公开。 必填项已用*标注