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

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

Method Summary

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, 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, foreach, foreach, foreachRDD, foreachRDD, glom, map, mapPartitions, mapPartitionsToPair, mapToPair, print, print, reduce, reduceByWindow, 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()