org.apache.spark.streaming

Class StreamingSource

Object

org.apache.spark.streaming.StreamingSource

All Implemented Interfaces:

Source

public class StreamingSource
extends Object
implements Source

Constructor Summary

Constructors

Constructor and Description
StreamingSource(StreamingContext ssc)

Method Summary

Methods

Modifier and Type	Method and Description
com.codahale.metrics.MetricRegistry	metricRegistry()
String	sourceName()

Methods inherited from class Object

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

Constructor Detail

StreamingSource

public StreamingSource(StreamingContext ssc)

Method Detail

metricRegistry

public com.codahale.metrics.MetricRegistry metricRegistry()

Specified by:

metricRegistry in interface Source

sourceName

public String sourceName()

Specified by:

sourceName in interface Source