| インターフェース | 説明 |
|---|---|
| Processor<I extends org.apache.spark.streaming.api.java.JavaDStreamLike,O extends org.apache.spark.streaming.api.java.JavaDStreamLike> | Spark ストリーミング API を使用してメッセージバスからのメッセージを処理する Java ベースのモジュールのインターフェース。 |
| クラス | 説明 |
|---|---|
| ModuleExecutor | Processor のプロセスメソッドを呼び出し、存在する場合は出力 DStream を処理します。 |