org.apache.spark.streaming.api.java

Class JavaReceiverInputDStream<T>

Object

org.apache.spark.streaming.api.java.JavaDStream<T>

org.apache.spark.streaming.api.java.JavaInputDStream<T>

org.apache.spark.streaming.api.java.JavaReceiverInputDStream<T>

All Implemented Interfaces:

java.io.Serializable, JavaDStreamLike<T,JavaDStream<T>,JavaRDD<T>>

public class JavaReceiverInputDStream<T>
extends JavaInputDStream<T>

A Java-friendly interface to ReceiverInputDStream, the abstract class for defining any input stream that receives data over the network.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
JavaReceiverInputDStream(ReceiverInputDStream<T> receiverInputDStream, scala.reflect.ClassTag<T> classTag)

Method Summary

Modifier and Type	Method and Description
scala.reflect.ClassTag<T>	classTag()
static <T> JavaReceiverInputDStream<T>	fromReceiverInputDStream(ReceiverInputDStream<T> receiverInputDStream, scala.reflect.ClassTag<T> evidence$1) Convert a scala ReceiverInputDStream to a Java-friendly JavaReceiverInputDStream.
ReceiverInputDStream<T>	receiverInputDStream()

Methods inherited from class org.apache.spark.streaming.api.java.JavaInputDStream

fromInputDStream, inputDStream

Methods inherited from class org.apache.spark.streaming.api.java.JavaDStream

cache, compute, dstream, filter, fromDStream, persist, persist, repartition, union, window, window, wrapRDD

Methods inherited from class Object

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

Methods inherited from interface org.apache.spark.streaming.api.java.JavaDStreamLike

checkpoint, context, count, countByValue, countByValue, countByValueAndWindow, countByValueAndWindow, countByWindow, flatMap, flatMapToPair, foreachRDD, foreachRDD, glom, map, mapPartitions, mapPartitionsToPair, mapToPair, print, print, reduce, reduceByWindow, reduceByWindow, scalaIntToJavaLong, slice, transform, transform, transformToPair, transformToPair, transformWith, transformWith, transformWithToPair, transformWithToPair

Constructor Detail

JavaReceiverInputDStream

public JavaReceiverInputDStream(ReceiverInputDStream<T> receiverInputDStream,
                                scala.reflect.ClassTag<T> classTag)

Method Detail

fromReceiverInputDStream

public static <T> JavaReceiverInputDStream<T> fromReceiverInputDStream(ReceiverInputDStream<T> receiverInputDStream,
                                                                       scala.reflect.ClassTag<T> evidence$1)

Convert a scala ReceiverInputDStream to a Java-friendly JavaReceiverInputDStream.

Parameters:

receiverInputDStream - (undocumented)

evidence$1 - (undocumented)

Returns:

(undocumented)

receiverInputDStream

public ReceiverInputDStream<T> receiverInputDStream()

classTag

public scala.reflect.ClassTag<T> classTag()

Specified by:

classTag in interface JavaDStreamLike<T,JavaDStream<T>,JavaRDD<T>>

Overrides:

classTag in class JavaInputDStream<T>