Class JavaInputDStream<T>
Object
org.apache.spark.streaming.api.java.JavaDStream<T>
org.apache.spark.streaming.api.java.JavaInputDStream<T>
- All Implemented Interfaces:
Serializable
,JavaDStreamLike<T,
,JavaDStream<T>, JavaRDD<T>> scala.Serializable
- Direct Known Subclasses:
JavaReceiverInputDStream
A Java-friendly interface to
InputDStream
.- See Also:
-
Constructor Summary
ConstructorDescriptionJavaInputDStream
(InputDStream<T> inputDStream, scala.reflect.ClassTag<T> classTag) -
Method Summary
Modifier and TypeMethodDescriptionscala.reflect.ClassTag<T>
classTag()
static <T> JavaInputDStream<T>
fromInputDStream
(InputDStream<T> inputDStream, scala.reflect.ClassTag<T> evidence$1) Convert a scalaInputDStream
to a Java-friendlyJavaInputDStream
.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
-
JavaInputDStream
-
-
Method Details
-
fromInputDStream
public static <T> JavaInputDStream<T> fromInputDStream(InputDStream<T> inputDStream, scala.reflect.ClassTag<T> evidence$1) Convert a scalaInputDStream
to a Java-friendlyJavaInputDStream
.- Parameters:
inputDStream
- (undocumented)evidence$1
- (undocumented)- Returns:
- (undocumented)
-
inputDStream
-
classTag
- Specified by:
classTag
in interfaceJavaDStreamLike<T,
JavaDStream<T>, JavaRDD<T>> - Overrides:
classTag
in classJavaDStream<T>
-