org.springframework.xd.spark.streaming

Class DefaultSparkStreamingModuleOptionsMetadata

java.lang.Object

org.springframework.xd.spark.streaming.DefaultSparkStreamingModuleOptionsMetadata

Direct Known Subclasses:

FileLoggerModuleOptionsMetadata

public class DefaultSparkStreamingModuleOptionsMetadata
extends java.lang.Object

Default module options for SparkStreamingSupport. Both the java and scala based implementations can extend this.

Author:

Ilayaperumal Gopinathan

Constructor Summary

Constructors

Constructor and Description
DefaultSparkStreamingModuleOptionsMetadata()

Method Summary

Methods

Modifier and Type	Method and Description
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)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultSparkStreamingModuleOptionsMetadata

public DefaultSparkStreamingModuleOptionsMetadata()

Method Detail

setBatchInterval

public void setBatchInterval(java.lang.String batchInterval)

getBatchInterval

public java.lang.String getBatchInterval()

setStorageLevel

public void setStorageLevel(java.lang.String storageLevel)

getStorageLevel

public java.lang.String getStorageLevel()

isSparkStorageValid

@AssertTrue(message="Use a valid storage level option. See org.apache.spark.storage.StorageLevel")
public boolean isSparkStorageValid()

setEnableTap

public void setEnableTap(boolean enableTap)

isEnableTap

public boolean isEnableTap()

getModuleExecutionFramework

public java.lang.String getModuleExecutionFramework()