Name | Description | Type | Package | Framework |
DefaultSparkStreamingModuleOptionsMetadata | Default module options for SparkStreamingSupport. | Class | org.springframework.xd.spark.streaming | Spring XD |
FileLogger | Class | org.springframework.xd.spark.streaming.examples.java | Spring XD | |
FileLoggerModuleOptionsMetadata | Class | org.springframework.xd.spark.streaming.examples.java | Spring XD | |
ModuleExecutor | Invokes the process method of a Processorand handles the output DStream if present. | Class | org.springframework.xd.spark.streaming.java | Spring XD |
Processor | Interface for the Java based modules using the Spark Streaming API to process messages from the Message Bus. | Interface | org.springframework.xd.spark.streaming.java | Spring XD |
SparkMessageSender | Abstract class that defines abstract methods to support sending the computed messages out of Spark clusterto XD MessageBus etc. | Class | org.springframework.xd.spark.streaming | Spring XD |
SparkStreamingModuleExecutor | The interface that streaming module executor will implement that runs the computation logic on the input DStreamand send the output via $SparkMessageSender. | Interface | org.springframework.xd.spark.streaming | Spring XD |
SparkStreamingSupport | Base interface for spring XD and spark streaming integration. | Interface | org.springframework.xd.spark.streaming | Spring XD |
WordCount | Class | org.springframework.xd.spark.streaming.examples.java | Spring XD | |