co.cask.cdap.etl.spark.plugin

Class WrappedStreamingSource<T>

java.lang.Object

co.cask.cdap.etl.api.streaming.StreamingSource<T>

co.cask.cdap.etl.spark.plugin.WrappedStreamingSource<T>

Type Parameters:

T - type of object contained in the stream

All Implemented Interfaces:

PipelineConfigurable, Serializable

public class WrappedStreamingSource<T>
extends StreamingSource<T>

Wrapper around a Windower that makes sure logging, classloading, and other pipeline capabilities are setup correctly.

See Also:

Serialized Form

Field Summary

Fields inherited from class co.cask.cdap.etl.api.streaming.StreamingSource

PLUGIN_TYPE

Constructor Summary

Constructors

Constructor and Description
WrappedStreamingSource(StreamingSource<T> source, Caller caller)

Method Summary

Modifier and Type	Method and Description
void	configurePipeline(PipelineConfigurer pipelineConfigurer)
org.apache.spark.streaming.api.java.JavaDStream<T>	getStream(StreamingContext context)

Methods inherited from class co.cask.cdap.etl.api.streaming.StreamingSource

getRequiredExecutors

Methods inherited from class java.lang.Object

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

Constructor Detail

WrappedStreamingSource

public WrappedStreamingSource(StreamingSource<T> source,
                              Caller caller)

Method Detail

configurePipeline

public void configurePipeline(PipelineConfigurer pipelineConfigurer)
                       throws IllegalArgumentException

Specified by:

configurePipeline in interface PipelineConfigurable

Overrides:

configurePipeline in class StreamingSource<T>

Throws:

IllegalArgumentException

getStream

public org.apache.spark.streaming.api.java.JavaDStream<T> getStream(StreamingContext context)
                                                             throws Exception

Specified by:

getStream in class StreamingSource<T>

Throws:

Exception