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
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, foreach, foreach, foreachRDD, foreachRDD, glom, map, mapPartitions, mapPartitionsToPair, mapToPair, print, print, reduce, reduceByWindow, reduceByWindow, reduceByWindow, scalaIntToJavaLong, slice, transform, transform, transformToPair, transformToPair, transformWith, transformWith, transformWithToPair, transformWithToPair |
JavaReceiverInputDStream
public JavaReceiverInputDStream(ReceiverInputDStream<T> receiverInputDStream,
scala.reflect.ClassTag<T> classTag)
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>