org.apache.spark.streaming.api

java

package java

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 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.

  4. class JavaStreamingContext extends AnyRef

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

  5. trait JavaStreamingContextFactory extends AnyRef

    Factory interface for creating a new JavaStreamingContext

Value Members

  1. object JavaDStream extends Serializable

  2. object JavaPairDStream extends Serializable

  3. object JavaStreamingContext

    JavaStreamingContext object contains a number of utility functions.

Ungrouped