SparkStreamingPlugin (Spring XD 1.3.2.RELEASE API)

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

実装済みのインターフェース一覧:
org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware, org.springframework.core.Ordered, Plugin
```
public class SparkStreamingPlugin
extends AbstractStreamPlugin
```
Spark ストリーミングサポート用のプラグイン。このプラグインは、基盤となる MessageBus に接続してメッセージを受信 / 送信する Spark ストリーミングモジュールに必要な Bean を設定します。
導入:
1.1
作成者:
Ilayaperumal Gopinathan, Mark Fisher, Eric Bottard

フィールド概要
- クラス org.springframework.xd.dirt.plugins.AbstractMessageBusBinderPlugin から継承されたフィールド
  JOB_CHANNEL_PREFIX, messageBus, MODULE_INPUT_CHANNEL, MODULE_OUTPUT_CHANNEL
- クラス org.springframework.xd.dirt.plugins.AbstractPlugin から継承されたフィールド
  PLUGIN_CONTEXT_CONFIG_ROOT
- インターフェース org.springframework.core.Ordered から継承されたフィールド
  HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

コンストラクター概要
コンストラクター
コンストラクターと説明
SparkStreamingPlugin(MessageBus messageBus)

コンストラクター
コンストラクターと説明
`SparkStreamingPlugin(MessageBus messageBus)`

方法の概要

メソッド
修飾子と型	メソッドと説明
`void`	`beforeShutdown(Module module)` モジュールをシャットダウンする前に必要なクリーンアップを実行します
`void`	`postProcessModule(Module module)` モジュールが初期化された後、つまりコンテキストがリフレッシュされた後、モジュールが起動される前に、モジュールに変更を適用します。
`boolean`	`supports(Module module)` モジュールがプラグインでサポートされているかどうかを確認します。

クラス org.springframework.xd.dirt.plugins.AbstractStreamPlugin から継承されたメソッド
buildTapChannelName, getInputChannelName, getOutputChannelName

クラス org.springframework.xd.dirt.plugins.AbstractMessageBusBinderPlugin から継承されたメソッド
bindConsumerAndProducers, extractConsumerProducerProperties, extractHistoryProperties, getOrder, removeModule, unbindConsumer, unbindProducers

クラス org.springframework.xd.dirt.plugins.AbstractPlugin から継承されたメソッド
getApplicationContext, preProcessModule, setApplicationContext

クラス java.lang.Object から継承されたメソッド
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- コンストラクターの詳細
  - SparkStreamingPlugin
```
@Autowired
public SparkStreamingPlugin(MessageBus messageBus)
```
- メソッドの詳細
  - supports
```
public boolean supports(Module module)
```
    インターフェースからコピーされた説明: Plugin
    モジュールがプラグインでサポートされているかどうかを確認します。
    次で指定:
    インターフェース Plugin 内の supports
    オーバーライド:
    クラス AbstractStreamPlugin の supports
    パラメーター:
    module - サポートを確認するモジュール
  - postProcessModule
```
public void postProcessModule(Module module)
```
    インターフェースからコピーされた説明: Plugin
    モジュールが初期化された後、つまりコンテキストがリフレッシュされた後、モジュールが起動される前に、モジュールに変更を適用します。
    次で指定:
    インターフェース Plugin 内の postProcessModule
    オーバーライド:
    クラス AbstractPlugin の postProcessModule
    パラメーター:
    module - 後処理モジュール
  - beforeShutdown
```
public void beforeShutdown(Module module)
```
    インターフェースからコピーされた説明: Plugin
    モジュールをシャットダウンする前に必要なクリーンアップを実行します
    次で指定:
    インターフェース Plugin 内の beforeShutdown
    オーバーライド:
    クラス AbstractMessageBusBinderPlugin の beforeShutdown
    パラメーター:
    module - クリーンアップするモジュール

クラス SparkStreamingPlugin

フィールド概要

クラス org.springframework.xd.dirt.plugins.AbstractMessageBusBinderPlugin から継承されたフィールド

クラス org.springframework.xd.dirt.plugins.AbstractPlugin から継承されたフィールド

インターフェース org.springframework.core.Ordered から継承されたフィールド

コンストラクター概要

方法の概要

クラス org.springframework.xd.dirt.plugins.AbstractStreamPlugin から継承されたメソッド

クラス org.springframework.xd.dirt.plugins.AbstractMessageBusBinderPlugin から継承されたメソッド

クラス org.springframework.xd.dirt.plugins.AbstractPlugin から継承されたメソッド

クラス java.lang.Object から継承されたメソッド

コンストラクターの詳細

SparkStreamingPlugin

メソッドの詳細

supports

postProcessModule

beforeShutdown