Package 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:

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	Description
JavaPairReceiverInputDStream(ReceiverInputDStream<scala.Tuple2<K,V>> receiverInputDStream, scala.reflect.ClassTag<K> kClassTag, scala.reflect.ClassTag<V> vClassTag)

Method Summary

Modifier and Type	Method	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 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 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>