Spark Streaming
出典: フリー百科事典『ウィキペディア(Wikipedia)』 (2020/11/24 07:50 UTC 版)
「Apache Spark」の記事における「Spark Streaming」の解説
Spark Coreの高速スケジューリング機能を活用してストリーミング分析を実行する。ミニバッチでデータを取り込み、RDD変換を実行する。この設計により、バッチ分析用に記述されたアプリケーションコードセットを使用できるため、 ラムダアーキテクチャの実装が容易になる。 しかし、この利便性はミニバッチ持続時間に等しいレイテンシのペナルティを伴う。ミニバッチではなくイベント別にイベントを処理するその他のストリーミングデータエンジンには、StormとFlinkのストリーミングコンポーネントが含まれる。Spark Streamingは、Kafka、Flume、Twitter、ZeroMQ、Kinesis、TCP/IPソケットに対応している。
※この「Spark Streaming」の解説は、「Apache Spark」の解説の一部です。
「Spark Streaming」を含む「Apache Spark」の記事については、「Apache Spark」の概要を参照ください。
- Spark Streamingのページへのリンク