Package org.apache.spark.streaming.api.java

Java APIs for spark streaming.

See:
Description

Interface Summary

JavaDStreamLike<T,This extends JavaDStreamLike<T,This,R>,R extends JavaRDDLike<T,R>>
JavaStreamingContextFactory	Factory interface for creating a new JavaStreamingContext

Class Summary

JavaDStream<T>	A Java-friendly interface to DStream, the basic abstraction in Spark Streaming that represents a continuous stream of data.
JavaInputDStream<T>	A Java-friendly interface to InputDStream.
JavaPairDStream<K,V>	A Java-friendly interface to a DStream of key-value pairs, which provides extra methods like reduceByKey and join.
JavaPairInputDStream<K,V>	A Java-friendly interface to InputDStream of key-value pairs.
JavaPairReceiverInputDStream<K,V>	A Java-friendly interface to ReceiverInputDStream, the abstract class for defining any input stream that receives data over the network.
JavaReceiverInputDStream<T>	A Java-friendly interface to ReceiverInputDStream, the abstract class for defining any input stream that receives data over the network.
JavaStreamingContext	A Java-friendly version of StreamingContext which is the main entry point for Spark Streaming functionality.

Package org.apache.spark.streaming.api.java Description

Java APIs for spark streaming.