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>> scala.Serializable
A Java-friendly interface to
ReceiverInputDStream
, the
abstract class for defining any input stream that receives data over the network.- See Also:
-
Constructor Summary
ConstructorDescriptionJavaReceiverInputDStream
(ReceiverInputDStream<T> receiverInputDStream, scala.reflect.ClassTag<T> classTag) -
Method Summary
Modifier and TypeMethodDescriptionscala.reflect.ClassTag<T>
classTag()
static <T> JavaReceiverInputDStream<T>
fromReceiverInputDStream
(ReceiverInputDStream<T> receiverInputDStream, scala.reflect.ClassTag<T> evidence$1) Convert a scalaReceiverInputDStream
to a Java-friendlyJavaReceiverInputDStream
.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 scalaReceiverInputDStream
to a Java-friendlyJavaReceiverInputDStream
.- Parameters:
receiverInputDStream
- (undocumented)evidence$1
- (undocumented)- Returns:
- (undocumented)
-
receiverInputDStream
-
classTag
- Specified by:
classTag
in interfaceJavaDStreamLike<T,
JavaDStream<T>, JavaRDD<T>> - Overrides:
classTag
in classJavaInputDStream<T>
-