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>>, scala.Serializable

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:
  • Constructor Details

    • JavaPairReceiverInputDStream

      public JavaPairReceiverInputDStream(ReceiverInputDStream<scala.Tuple2<K,V>> receiverInputDStream, scala.reflect.ClassTag<K> kClassTag, scala.reflect.ClassTag<V> vClassTag)
  • Method Details