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>>, scala.Serializable
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:
  • 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()