このトピックでは、Spark ストリーミング SQL で INSERT INTO 文を使用する方法について説明します。
構文
INSERT INTO tbName[(columnName[,columnName]*)]
queryStatement;
例
INSERT INTO LargeOrders
SELECT * FROM Orders WHERE units > 1000;
注意
- Spark ストリーミング SQL では、クエリに単独の SELECT 文を使用できません。 SELECT 文は、CTAS 文と一緒に使用するか、INSERT INTO 文に含める必要があります。
- 1 つのジョブの場合、SQL ファイルには複数のデータ操作言語 (DML) 操作、および複数のデータソースとターゲットを含めることができます。