org.springframework.xd.spark.streaming

Interface SparkStreamingModuleExecutor<I,P extends SparkStreamingSupport>

All Known Implementing Classes:

ModuleExecutor

public interface SparkStreamingModuleExecutor<I,P extends SparkStreamingSupport>

The interface that streaming module executor will implement that runs the computation logic on the input DStream and send the output via $SparkMessageSender.

Since:

1.1

Author:

Ilayaperumal Gopinathan

Method Summary

Methods

Modifier and Type	Method and Description
void	execute(I input, P processor, SparkMessageSender sender) The execute method that runs the computation on input by invoking the underlying processor's process method and make the output available for $SparkMessageSender if needed.

Method Detail

execute

void execute(I input,
           P processor,
           SparkMessageSender sender)

The execute method that runs the computation on input by invoking the underlying processor's process method and make the output available for $SparkMessageSender if needed.

Parameters:

input - the input received by the spark streaming receiver

processor - the underlying processor implementation (java or scala based)

sender - the message sender