public interface SparkStreamingModuleExecutor<I,P extends SparkStreamingSupport>SparkMessageSender 経由で送信します。| 修飾子と型 | メソッドと説明 |
|---|---|
void | execute(I input, P processor, SparkMessageSender sender) 実行メソッドは、基になるプロセッサーのプロセスメソッドを呼び出して入力の計算を実行し、必要に応じて出力を $ SparkMessageSender で使用できるようにします。 |
void execute(I input, P processor, SparkMessageSender sender)
SparkMessageSender で使用できるようにします。input - スパークストリーミングレシーバーが受信した入力 processor - 基盤となるプロセッサーの実装 (java または Scala ベース)sender - メッセージの送信者