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

package org.apache.spark.streaming.api.java

Java APIs for spark streaming.

Class	Description
JavaDStream<T>	A Java-friendly interface to DStream, the basic abstraction in Spark Streaming that represents a continuous stream of data.
JavaDStreamLike<T,This extends JavaDStreamLike<T,This,R>,R extends JavaRDDLike<T,R>>
JavaInputDStream<T>	A Java-friendly interface to InputDStream.
JavaMapWithStateDStream<KeyType,ValueType,StateType,MappedType>	DStream representing the stream of data generated by mapWithState operation on a JavaPairDStream.
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	Deprecated. This is deprecated as of Spark 3.4.0.
JavaStreamingListenerEvent	Base trait for events related to JavaStreamingListener
PythonStreamingListener