Package org.springframework.xd.spark.streaming.java

Package for java based spark streaming integration support.

See: Description

Interface Summary

Interface	Description
Processor<I extends org.apache.spark.streaming.api.java.JavaDStreamLike,O extends org.apache.spark.streaming.api.java.JavaDStreamLike>	Interface for the Java based modules using the Spark Streaming API to process messages from the Message Bus.

Class Summary

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

Package org.springframework.xd.spark.streaming.java Description

Package for java based spark streaming integration support.