Interface | Description |
---|---|
JavaDStreamLike<T,This extends JavaDStreamLike<T,This,R>,R extends JavaRDDLike<T,R>> | |
JavaStreamingContextFactory |
Factory interface for creating a new JavaStreamingContext
|
Class | Description |
---|---|
AbstractJavaDStreamLike<T,This extends JavaDStreamLike<T,This,R>,R extends JavaRDDLike<T,R>> |
As a workaround for https://issues.scala-lang.org/browse/SI-8905, implementations
of JavaDStreamLike should extend this dummy abstract class instead of directly inheriting
from the trait.
|
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. |