
202
10
章
Structured Streaming
4. ブロック ID の情報はドライバ上のブロック管理マスターに転送されます。
5. Spark Streaming Context 内で設定されたバッチインターバル(通常は1秒間隔です)ごとに、
ドライバはブロックを処理する Spark のタスクを起動します。そしてこれらのブロックは、クラウ
ドのストレージ(たとえば S3、WASB など)、リレーショナルデータストア(たとえば MySQL や
PostgreSQL な ど )、 NoSQL ストアといった任意の数のターゲットデータストアに永続化されます。
ストリーミングのアプリケーションには常に最適化や設定をし続けなければならない可動部分がた
くさんある、ということは述べておきましょう。Spark Streamingのドキュメンテーションの多くは、
Scalaについて書かれた部分の方が多くなっているので、Python APIを扱う場合でも Scalaバージョ
ンのドキュメンテーションを参照しなければならないこともあるでしょう。そういった場合に提案した
い修正があるなら、バグやプルリクエストを登録してください(https://issues.apache.org/jira/browse/
spark/)。
このトピックに関する詳しい情報は、次を参照してください。
●
Spark 1.6 Streaming Programming Guide(https://spark.apache.or