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

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	Description
JavaPairInputDStream(InputDStream<scala.Tuple2<K,V>> inputDStream, scala.reflect.ClassTag<K> kClassTag, scala.reflect.ClassTag<V> vClassTag)

Method Summary

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

JavaPairInputDStream

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

Method Details

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()