org.springframework.xd.spark.streaming

Interface SparkStreamingSupport

All Superinterfaces:

java.io.Serializable

All Known Subinterfaces:

Processor<I,O>

All Known Implementing Classes:

FileLogger, WordCount

public interface SparkStreamingSupport
extends java.io.Serializable

Base interface for spring XD and spark streaming integration.

Since:

1.1

Author:

Ilayaperumal Gopinathan

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	MODULE_EXECUTION_FRAMEWORK The module execution framework is used by XD runtime to determine the module as the spark streaming module.
static java.lang.String	SPARK_DEFAULT_MASTER_URL
static java.lang.String	SPARK_DEFAULT_STORAGE_LEVEL
static java.lang.String	SPARK_MASTER_URL_PROP
static java.lang.String	SPARK_STORAGE_LEVEL_MODULE_OPTION
static java.lang.String	SPARK_STORAGE_LEVEL_PROP
static java.lang.String	SPARK_STREAMING_BATCH_INTERVAL_MODULE_OPTION
static java.lang.String	SPARK_STREAMING_BATCH_INTERVAL_PROP
static java.lang.String	SPARK_STREAMING_DEFAULT_BATCH_INTERVAL

Field Detail

SPARK_MASTER_URL_PROP

static final java.lang.String SPARK_MASTER_URL_PROP

See Also:

Constant Field Values

SPARK_DEFAULT_MASTER_URL

static final java.lang.String SPARK_DEFAULT_MASTER_URL

See Also:

Constant Field Values

SPARK_STORAGE_LEVEL_PROP

static final java.lang.String SPARK_STORAGE_LEVEL_PROP

See Also:

Constant Field Values

SPARK_STORAGE_LEVEL_MODULE_OPTION

static final java.lang.String SPARK_STORAGE_LEVEL_MODULE_OPTION

See Also:

Constant Field Values

SPARK_DEFAULT_STORAGE_LEVEL

static final java.lang.String SPARK_DEFAULT_STORAGE_LEVEL

See Also:

Constant Field Values

SPARK_STREAMING_BATCH_INTERVAL_PROP

static final java.lang.String SPARK_STREAMING_BATCH_INTERVAL_PROP

See Also:

Constant Field Values

SPARK_STREAMING_BATCH_INTERVAL_MODULE_OPTION

static final java.lang.String SPARK_STREAMING_BATCH_INTERVAL_MODULE_OPTION

See Also:

Constant Field Values

SPARK_STREAMING_DEFAULT_BATCH_INTERVAL

static final java.lang.String SPARK_STREAMING_DEFAULT_BATCH_INTERVAL

See Also:

Constant Field Values

MODULE_EXECUTION_FRAMEWORK

static final java.lang.String MODULE_EXECUTION_FRAMEWORK

The module execution framework is used by XD runtime to determine the module as the spark streaming module.

See Also:

Constant Field Values