public class ModuleExecutor extends java.lang.Object implements SparkStreamingModuleExecutor<org.apache.spark.streaming.api.java.JavaReceiverInputDStream,Processor>, java.io.Serializable
Processor のプロセスメソッドを呼び出し、存在する場合は出力 DStream を処理します。| コンストラクターと説明 |
|---|
ModuleExecutor() |
| 修飾子と型 | メソッドと説明 |
|---|---|
void | execute(org.apache.spark.streaming.api.java.JavaReceiverInputDStream input, Processor processor, SparkMessageSender sender) 実行メソッドは、基になるプロセッサーのプロセスメソッドを呼び出して入力の計算を実行し、必要に応じて出力を $ SparkMessageSender で使用できるようにします。 |
public void execute(org.apache.spark.streaming.api.java.JavaReceiverInputDStream input,
Processor processor,
SparkMessageSender sender)SparkStreamingModuleExecutorSparkMessageSender で使用できるようにします。SparkStreamingModuleExecutor<org.apache.spark.streaming.api.java.JavaReceiverInputDStream,Processor> 内の execute input - スパークストリーミングレシーバーが受信した入力 processor - 基盤となるプロセッサーの実装 (java または Scala ベース)sender - メッセージの送信者