org.springframework.xd.spark.streaming

Class SparkStreamingModuleExecutor

java.lang.Object

org.springframework.xd.spark.streaming.SparkStreamingModuleExecutor

All Implemented Interfaces:

java.io.Serializable

public class SparkStreamingModuleExecutor
extends java.lang.Object
implements java.io.Serializable

Invokes the process method of a Processor and handles the output DStream if present.

Author:

Ilayaperumal Gopinathan, Mark Fisher

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SparkStreamingModuleExecutor()

Method Summary

Methods

Modifier and Type	Method and Description
void	execute(org.apache.spark.streaming.api.java.JavaDStream input, Processor processor, SparkMessageSender sender)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SparkStreamingModuleExecutor

public SparkStreamingModuleExecutor()

Method Detail

execute

public void execute(org.apache.spark.streaming.api.java.JavaDStream input,
           Processor processor,
           SparkMessageSender sender)