public class SparkStreamingPlugin extends AbstractStreamPlugin
MessageBus to receive/send messages.JOB_CHANNEL_PREFIX, messageBus, MODULE_INPUT_CHANNEL, MODULE_OUTPUT_CHANNELPLUGIN_CONTEXT_CONFIG_ROOT| Constructor and Description |
|---|
SparkStreamingPlugin(MessageBus messageBus,
ZooKeeperConnection zkConnection) |
| 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.
|
buildTapChannelName, getInputChannelName, getOutputChannelNamebindConsumerAndProducers, extractConsumerProducerProperties, extractHistoryProperties, getOrder, removeModule, unbindConsumer, unbindProducersgetApplicationContext, preProcessModule, setApplicationContext@Autowired public SparkStreamingPlugin(MessageBus messageBus, ZooKeeperConnection zkConnection)
public boolean supports(Module module)
Pluginsupports in interface Pluginsupports in class AbstractStreamPluginmodule - the module to check for supportpublic void postProcessModule(Module module)
PluginpostProcessModule in interface PluginpostProcessModule in class AbstractPluginmodule - the module to post-processpublic void beforeShutdown(Module module)
PluginbeforeShutdown in interface PluginbeforeShutdown in class AbstractMessageBusBinderPluginmodule - the module to cleanup