org.apache.spark.streaming.api.java

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:

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

Direct Known Subclasses:

JavaPairReceiverInputDStream

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

A Java-friendly interface to InputDStream of key-value pairs.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
JavaPairInputDStream(InputDStream<scala.Tuple2<K,V>> inputDStream, scala.reflect.ClassTag<K> kClassTag, scala.reflect.ClassTag<V> vClassTag)

Method Summary

Modifier and Type	Method and Description
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 scala InputDStream of pairs to a Java-friendly JavaPairInputDStream.
InputDStream<scala.Tuple2<K,V>>	inputDStream()
scala.reflect.ClassTag<K>	kClassTag()
scala.reflect.ClassTag<V>	vClassTag()

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

JavaPairInputDStream

public JavaPairInputDStream(InputDStream<scala.Tuple2<K,V>> inputDStream,
                            scala.reflect.ClassTag<K> kClassTag,
                            scala.reflect.ClassTag<V> vClassTag)

Method Detail

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 scala InputDStream of pairs to a Java-friendly JavaPairInputDStream.

Parameters:

inputDStream - (undocumented)

evidence$1 - (undocumented)

evidence$2 - (undocumented)

Returns:

(undocumented)

inputDStream

public InputDStream<scala.Tuple2<K,V>> inputDStream()

kClassTag

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

vClassTag

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