java

Type Members

1. class JavaDStream[T] extends AbstractJavaDStreamLike[T, JavaDStream[T], JavaRDD[T]]

   A Java-friendly interface to org.apache.spark.streaming.dstream.DStream, the basic abstraction in Spark Streaming that represents a continuous stream of data.

2. trait JavaDStreamLike[T, This <: JavaDStreamLike[T, This, R], R <: JavaRDDLike[T, R]] extends Serializable

3. class JavaInputDStream[T] extends JavaDStream[T]

   A Java-friendly interface to org.apache.spark.streaming.dstream.InputDStream.

4. class JavaPairDStream[K, V] extends AbstractJavaDStreamLike[(K, V), JavaPairDStream[K, V], JavaPairRDD[K, V]]

   A Java-friendly interface to a DStream of key-value pairs, which provides extra methods like reduceByKey and join.

5. class JavaPairInputDStream[K, V] extends JavaPairDStream[K, V]

   A Java-friendly interface to org.apache.spark.streaming.dstream.InputDStream of key-value pairs.

6. class JavaPairReceiverInputDStream[K, V] extends JavaPairInputDStream[K, V]

   A Java-friendly interface to org.apache.spark.streaming.dstream.ReceiverInputDStream, the abstract class for defining any input stream that receives data over the network.

7. class JavaReceiverInputDStream[T] extends JavaInputDStream[T]

   A Java-friendly interface to org.apache.spark.streaming.dstream.ReceiverInputDStream, the abstract class for defining any input stream that receives data over the network.

8. class JavaStreamingContext extends Closeable

   A Java-friendly version of org.apache.spark.streaming.StreamingContext which is the main entry point for Spark Streaming functionality.

9. trait JavaStreamingContextFactory extends AnyRef

   Factory interface for creating a new JavaStreamingContext