org.apache.spark.streaming.api.java

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:

java.io.Serializable, JavaDStreamLike<scala.Tuple2<K,V>,JavaPairDStream<K,V>,JavaPairRDD<K,V>>

public class JavaPairReceiverInputDStream<K,V>
extends JavaPairInputDStream<K,V>

A Java-friendly interface to ReceiverInputDStream, the abstract class for defining any input stream that receives data over the network.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
JavaPairReceiverInputDStream(ReceiverInputDStream<scala.Tuple2<K,V>> receiverInputDStream, scala.reflect.ClassTag<K> kClassTag, scala.reflect.ClassTag<V> vClassTag)

Method Summary

Modifier and Type	Method and Description
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 scala ReceiverInputDStream to a Java-friendly JavaReceiverInputDStream.
scala.reflect.ClassTag<K>	kClassTag()
ReceiverInputDStream<scala.Tuple2<K,V>>	receiverInputDStream()
scala.reflect.ClassTag<V>	vClassTag()

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 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 Detail

JavaPairReceiverInputDStream

public JavaPairReceiverInputDStream(ReceiverInputDStream<scala.Tuple2<K,V>> receiverInputDStream,
                                    scala.reflect.ClassTag<K> kClassTag,
                                    scala.reflect.ClassTag<V> vClassTag)

Method Detail

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 scala ReceiverInputDStream to a Java-friendly JavaReceiverInputDStream.

Parameters:

receiverInputDStream - (undocumented)

evidence$1 - (undocumented)

evidence$2 - (undocumented)

Returns:

(undocumented)

receiverInputDStream

public ReceiverInputDStream<scala.Tuple2<K,V>> receiverInputDStream()

kClassTag

public scala.reflect.ClassTag<K> kClassTag()

Overrides:

kClassTag in class JavaPairInputDStream<K,V>

vClassTag

public scala.reflect.ClassTag<V> vClassTag()

Overrides:

vClassTag in class JavaPairInputDStream<K,V>