Class JavaPairInputDStream<K,V>
Object
org.apache.spark.streaming.api.java.JavaPairDStream<K,V>
org.apache.spark.streaming.api.java.JavaPairInputDStream<K,V>
- All Implemented Interfaces:
Serializable
,JavaDStreamLike<scala.Tuple2<K,
,V>, JavaPairDStream<K, V>, JavaPairRDD<K, V>> scala.Serializable
- Direct Known Subclasses:
JavaPairReceiverInputDStream
A Java-friendly interface to
InputDStream
of
key-value pairs.- See Also:
-
Constructor Summary
ConstructorDescriptionJavaPairInputDStream
(InputDStream<scala.Tuple2<K, V>> inputDStream, scala.reflect.ClassTag<K> kClassTag, scala.reflect.ClassTag<V> vClassTag) -
Method Summary
Modifier and TypeMethodDescriptionstatic <K,
V> JavaPairInputDStream<K, V> fromInputDStream
(InputDStream<scala.Tuple2<K, V>> inputDStream, scala.reflect.ClassTag<K> evidence$1, scala.reflect.ClassTag<V> evidence$2) Convert a scalaInputDStream
of pairs to a Java-friendlyJavaPairInputDStream
.InputDStream<scala.Tuple2<K,
V>> scala.reflect.ClassTag<K>
scala.reflect.ClassTag<V>
Methods inherited from class org.apache.spark.streaming.api.java.JavaPairDStream
cache, classTag, cogroup, cogroup, cogroup, combineByKey, combineByKey, compute, dstream, filter, flatMapValues, fromJavaDStream, fromPairDStream, fullOuterJoin, fullOuterJoin, fullOuterJoin, groupByKey, groupByKey, groupByKey, groupByKeyAndWindow, groupByKeyAndWindow, groupByKeyAndWindow, groupByKeyAndWindow, join, join, join, kManifest, leftOuterJoin, leftOuterJoin, leftOuterJoin, mapValues, mapWithState, persist, persist, reduceByKey, reduceByKey, reduceByKey, reduceByKeyAndWindow, reduceByKeyAndWindow, reduceByKeyAndWindow, reduceByKeyAndWindow, reduceByKeyAndWindow, reduceByKeyAndWindow, reduceByKeyAndWindow, repartition, rightOuterJoin, rightOuterJoin, rightOuterJoin, saveAsHadoopFiles, saveAsHadoopFiles, saveAsHadoopFiles, saveAsNewAPIHadoopFiles, saveAsNewAPIHadoopFiles, saveAsNewAPIHadoopFiles, scalaToJavaLong, toJavaDStream, union, updateStateByKey, updateStateByKey, updateStateByKey, updateStateByKey, vManifest, 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
-
JavaPairInputDStream
public JavaPairInputDStream(InputDStream<scala.Tuple2<K, V>> inputDStream, scala.reflect.ClassTag<K> kClassTag, scala.reflect.ClassTag<V> vClassTag)
-
-
Method Details
-
fromInputDStream
public static <K,V> JavaPairInputDStream<K,V> fromInputDStream(InputDStream<scala.Tuple2<K, V>> inputDStream, scala.reflect.ClassTag<K> evidence$1, scala.reflect.ClassTag<V> evidence$2) Convert a scalaInputDStream
of pairs to a Java-friendlyJavaPairInputDStream
.- Parameters:
inputDStream
- (undocumented)evidence$1
- (undocumented)evidence$2
- (undocumented)- Returns:
- (undocumented)
-
inputDStream
-
kClassTag
-
vClassTag
-