Package org.springframework.xd.spark.streaming

Package for spark streaming integration.

See: Description

Interface Summary

Interface	Description
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.
SparkStreamingSupport	Base interface for spring XD and spark streaming integration.

Class Summary

Class	Description
DefaultSparkStreamingModuleOptionsMetadata	Default module options for SparkStreamingSupport.
SparkMessageSender	Abstract class that defines abstract methods to support sending the computed messages out of Spark cluster to XD MessageBus etc.

Annotation Types Summary

Annotation Type	Description
SparkConfig	Marker Annotation for providing spark configuration as properties.

Package org.springframework.xd.spark.streaming Description

Package for spark streaming integration.