Class JavaPairReceiverInputDStream<K,V>
Object
org.apache.spark.streaming.api.java.JavaPairDStream<K,V>
org.apache.spark.streaming.api.java.JavaPairInputDStream<K,V>
org.apache.spark.streaming.api.java.JavaPairReceiverInputDStream<K,V>
- All Implemented Interfaces:
Serializable
,JavaDStreamLike<scala.Tuple2<K,
,V>, JavaPairDStream<K, V>, JavaPairRDD<K, V>> 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
ConstructorDescriptionJavaPairReceiverInputDStream
(ReceiverInputDStream<scala.Tuple2<K, V>> receiverInputDStream, scala.reflect.ClassTag<K> kClassTag, scala.reflect.ClassTag<V> vClassTag) -
Method Summary
Modifier and TypeMethodDescriptionstatic <K,
V> JavaPairReceiverInputDStream<K, V> fromReceiverInputDStream
(ReceiverInputDStream<scala.Tuple2<K, V>> receiverInputDStream, scala.reflect.ClassTag<K> evidence$1, scala.reflect.ClassTag<V> evidence$2) Convert a scalaReceiverInputDStream
to a Java-friendlyJavaReceiverInputDStream
.scala.reflect.ClassTag<K>
ReceiverInputDStream<scala.Tuple2<K,
V>> scala.reflect.ClassTag<V>
Methods inherited from class org.apache.spark.streaming.api.java.JavaPairInputDStream
fromInputDStream, inputDStream
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
-
JavaPairReceiverInputDStream
public JavaPairReceiverInputDStream(ReceiverInputDStream<scala.Tuple2<K, V>> receiverInputDStream, scala.reflect.ClassTag<K> kClassTag, scala.reflect.ClassTag<V> vClassTag)
-
-
Method Details
-
fromReceiverInputDStream
public static <K,V> JavaPairReceiverInputDStream<K,V> fromReceiverInputDStream(ReceiverInputDStream<scala.Tuple2<K, V>> receiverInputDStream, scala.reflect.ClassTag<K> evidence$1, scala.reflect.ClassTag<V> evidence$2) Convert a scalaReceiverInputDStream
to a Java-friendlyJavaReceiverInputDStream
.- Parameters:
receiverInputDStream
- (undocumented)evidence$1
- (undocumented)evidence$2
- (undocumented)- Returns:
- (undocumented)
-
receiverInputDStream
-
kClassTag
- Overrides:
kClassTag
in classJavaPairInputDStream<K,
V>
-
vClassTag
- Overrides:
vClassTag
in classJavaPairInputDStream<K,
V>
-