| Interface | Description |
|---|---|
| JavaDStreamLike<T,This extends JavaDStreamLike<T,This,R>,R extends JavaRDDLike<T,R>> | |
| JavaStreamingListenerEvent |
Base trait for events related to JavaStreamingListener
|
| PythonStreamingListener |
| Class | Description |
|---|---|
| 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. |
| 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.
|