See: Description
| 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 | 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 Type | Description |
|---|---|
| SparkConfig |
Marker Annotation for providing spark configuration as properties.
|