public class DefaultSparkStreamingModuleOptionsMetadata
extends java.lang.Object
SparkStreamingSupport
のデフォルトのモジュールオプション。java と scala ベースの実装の両方でこれを継承できます。コンストラクターと説明 |
---|
DefaultSparkStreamingModuleOptionsMetadata() |
修飾子と型 | メソッドと説明 |
---|---|
java.lang.String | getBatchInterval() |
java.lang.String | getModuleExecutionFramework() |
java.lang.String | getStorageLevel() |
boolean | isEnableTap() |
boolean | isSparkStorageValid() |
void | setBatchInterval(java.lang.String batchInterval) |
void | setEnableTap(boolean enableTap) |
void | setStorageLevel(java.lang.String storageLevel) |
public DefaultSparkStreamingModuleOptionsMetadata()
public void setBatchInterval(java.lang.String batchInterval)
public java.lang.String getBatchInterval()
public void setStorageLevel(java.lang.String storageLevel)
public java.lang.String getStorageLevel()
@AssertTrue(message="Use a valid storage level option. See org.apache.spark.storage.StorageLevel") public boolean isSparkStorageValid()
public void setEnableTap(boolean enableTap)
public boolean isEnableTap()
public java.lang.String getModuleExecutionFramework()