org.springframework.xd.dirt.plugins.spark.streaming

Class SparkStreamingPlugin

java.lang.Object

org.springframework.xd.dirt.plugins.AbstractPlugin

org.springframework.xd.dirt.plugins.AbstractMessageBusBinderPlugin

org.springframework.xd.dirt.plugins.AbstractStreamPlugin

org.springframework.xd.dirt.plugins.spark.streaming.SparkStreamingPlugin

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware, org.springframework.core.Ordered, Plugin

public class SparkStreamingPlugin
extends AbstractStreamPlugin

Plugin for Spark Streaming support. This plugin sets up the necessary beans for the spark streaming module that connects to the underlying MessageBus to receive/send messages.

Since:

1.1

Author:

Ilayaperumal Gopinathan, Mark Fisher, Eric Bottard

Field Summary

Fields inherited from class org.springframework.xd.dirt.plugins.AbstractMessageBusBinderPlugin

JOB_CHANNEL_PREFIX, messageBus, MODULE_INPUT_CHANNEL, MODULE_OUTPUT_CHANNEL

Fields inherited from class org.springframework.xd.dirt.plugins.AbstractPlugin

PLUGIN_CONTEXT_CONFIG_ROOT

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor and Description
SparkStreamingPlugin(MessageBus messageBus)

Method Summary

Methods

Modifier and Type	Method and Description
void	beforeShutdown(Module module) Perform any cleanup necessary prior to module shutdown
void	postProcessModule(Module module) Apply changes to the module after it is initialized i.e. after its context is refreshed, but before it is started.
boolean	supports(Module module) Check if the module is supported by the plugin.

Methods inherited from class org.springframework.xd.dirt.plugins.AbstractStreamPlugin

buildTapChannelName, getInputChannelName, getOutputChannelName

Methods inherited from class org.springframework.xd.dirt.plugins.AbstractMessageBusBinderPlugin

bindConsumerAndProducers, extractConsumerProducerProperties, extractHistoryProperties, getOrder, removeModule, unbindConsumer, unbindProducers

Methods inherited from class org.springframework.xd.dirt.plugins.AbstractPlugin

getApplicationContext, preProcessModule, setApplicationContext

Methods inherited from class java.lang.Object

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

Constructor Detail

SparkStreamingPlugin

@Autowired
public SparkStreamingPlugin(MessageBus messageBus)

Method Detail

supports

public boolean supports(Module module)

Description copied from interface: Plugin

Check if the module is supported by the plugin.

Specified by:

supports in interface Plugin

Overrides:

supports in class AbstractStreamPlugin

Parameters:

module - the module to check for support

postProcessModule

public void postProcessModule(Module module)

Description copied from interface: Plugin

Apply changes to the module after it is initialized i.e. after its context is refreshed, but before it is started.

Specified by:

postProcessModule in interface Plugin

Overrides:

postProcessModule in class AbstractPlugin

Parameters:

module - the module to post-process

beforeShutdown

public void beforeShutdown(Module module)

Description copied from interface: Plugin

Perform any cleanup necessary prior to module shutdown

Specified by:

beforeShutdown in interface Plugin

Overrides:

beforeShutdown in class AbstractMessageBusBinderPlugin

Parameters:

module - the module to cleanup