Package 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:

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	Description
JavaReceiverInputDStream(ReceiverInputDStream<T> receiverInputDStream, scala.reflect.ClassTag<T> classTag)

Method Summary

Modifier and Type	Method	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 java.lang.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 Details

JavaReceiverInputDStream

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

Method Details

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>