このトピックでは、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) 操作、および複数のデータソースとターゲットを含めることができます。