org.apache.spark.streaming.api

java

package java

Spark streaming's Java API.

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. java
  2. AnyRef
  3. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Type Members

  1. class JavaDStream[T] extends JavaDStreamLike[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 JavaDStreamLike[(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

Value Members

  1. object JavaDStream extends Serializable

  2. object JavaInputDStream extends Serializable

  3. object JavaPairDStream extends Serializable

  4. object JavaPairInputDStream extends Serializable

  5. object JavaPairReceiverInputDStream extends Serializable

  6. object JavaReceiverInputDStream extends Serializable

  7. object JavaStreamingContext

    JavaStreamingContext object contains a number of utility functions.

Inherited from AnyRef

Inherited from Any

Ungrouped