Overview
Spark Connectorはストリーミング モードをサポートしています。このモードではSpark Structured Streaming が使用され、時間間隔が経過するのを待つのではなく、データが利用可能になるとすぐに処理されます。 Spark Structured Streaming は、Dataset または DataFrame API を使用してアクセスできるデータストリーム処理エンジンです。
重要
Apache Spark には 2 つの異なるストリーム処理エンジンが含まれています。
DStreams でのSpark Streaming はサポートされなくなりレガシーエンジン
このガイドは Spark Structured Streaming のみに関連します。
次のセクションでは、Spark Connector を使用して MongoDB からデータを読み取り、ストリーミング モードで MongoDB にデータを書き込む方法を説明します。