インターフェース | 説明 |
---|---|
SparkStreamingModuleExecutor<I,P extends SparkStreamingSupport> | ストリーミングモジュールエグゼキュータが実装するインターフェース。入力 DStream で計算ロジックを実行し、出力を $ SparkMessageSender 経由で送信します。 |
SparkStreamingSupport | Spring XD と Spark ストリーミング統合の基本インターフェース。 |
クラス | 説明 |
---|---|
DefaultSparkStreamingModuleOptionsMetadata | SparkStreamingSupport のデフォルトのモジュールオプション。 |
SparkMessageSender | 計算されたメッセージを Spark クラスターから XD MessageBus などに送信することをサポートする抽象メソッドを定義する抽象クラス。 |
アノテーション型 | 説明 |
---|---|
SparkConfig | Spark 構成をプロパティとして提供するためのマーカーアノテーション。 |