| Name | Type | Package | Detail |
| | | |
|
ByteArrayChunkOutputStream
|
Class
|
org.apache.spark.util.io
|
Detail
|
|
ByteBufferInputStream
|
Class
|
org.apache.spark.util
|
Detail
|
|
ConstantInputDStream
|
Class
|
org.apache.spark.streaming.dstream
|
Detail
|
|
DStream
|
Class
|
org.apache.spark.streaming.dstream
|
Detail
|
|
DeserializationStream
|
Class
|
org.apache.spark.serializer
|
Detail
|
|
FileInputDStream
|
Class
|
org.apache.spark.streaming.dstream
|
Detail
|
|
FilteredDStream
|
Class
|
org.apache.spark.streaming.dstream
|
Detail
|
|
FlatMapValuedDStream
|
Class
|
org.apache.spark.streaming.dstream
|
Detail
|
|
FlatMappedDStream
|
Class
|
org.apache.spark.streaming.dstream
|
Detail
|
|
FlumeInputDStream
|
Class
|
org.apache.spark.streaming.flume
|
Detail
|
|
FlumePollingInputDStream
|
Class
|
org.apache.spark.streaming.flume
|
Detail
|
|
ForEachDStream
|
Class
|
org.apache.spark.streaming.dstream
|
Detail
|
|
GlommedDStream
|
Class
|
org.apache.spark.streaming.dstream
|
Detail
|
|
InputDStream
|
Class
|
org.apache.spark.streaming.dstream
|
Detail
|
|
JavaDStream
|
Class
|
org.apache.spark.streaming.api.java
|
Detail
|
|
JavaDeserializationStream
|
Class
|
org.apache.spark.serializer
|
Detail
|
|
JavaInputDStream
|
Class
|
org.apache.spark.streaming.api.java
|
Detail
|
|
JavaPairDStream
|
Class
|
org.apache.spark.streaming.api.java
|
Detail
|
|
JavaPairInputDStream
|
Class
|
org.apache.spark.streaming.api.java
|
Detail
|
|
JavaPairReceiverInputDStream
|
Class
|
org.apache.spark.streaming.api.java
|
Detail
|
|
JavaReceiverInputDStream
|
Class
|
org.apache.spark.streaming.api.java
|
Detail
|
|
JavaSerializationStream
|
Class
|
org.apache.spark.serializer
|
Detail
|
|
KafkaInputDStream
|
Class
|
org.apache.spark.streaming.kafka
|
Detail
|
|
KryoDeserializationStream
|
Class
|
org.apache.spark.serializer
|
Detail
|
|
KryoSerializationStream
|
Class
|
org.apache.spark.serializer
|
Detail
|
|
MQTTInputDStream
|
Class
|
org.apache.spark.streaming.mqtt
|
Detail
|
|
MapPartitionedDStream
|
Class
|
org.apache.spark.streaming.dstream
|
Detail
|
|
MapValuedDStream
|
Class
|
org.apache.spark.streaming.dstream
|
Detail
|
|
MappedDStream
|
Class
|
org.apache.spark.streaming.dstream
|
Detail
|
|
PluggableInputDStream
|
Class
|
org.apache.spark.streaming.dstream
|
Detail
|
|
PortableDataStream
|
Class
|
org.apache.spark.input
|
Detail
|
|
QueueInputDStream
|
Class
|
org.apache.spark.streaming.dstream
|
Detail
|
|
RateLimitedOutputStream
|
Class
|
org.apache.spark.streaming.util
|
Detail
|
|
RawInputDStream
|
Class
|
org.apache.spark.streaming.dstream
|
Detail
|
|
ReceiverInputDStream
|
Class
|
org.apache.spark.streaming.dstream
|
Detail
|
|
ReducedWindowedDStream
|
Class
|
org.apache.spark.streaming.dstream
|
Detail
|
|
SerializationStream
|
Class
|
org.apache.spark.serializer
|
Detail
|
|
ShuffledDStream
|
Class
|
org.apache.spark.streaming.dstream
|
Detail
|
|
SocketInputDStream
|
Class
|
org.apache.spark.streaming.dstream
|
Detail
|
|
StateDStream
|
Class
|
org.apache.spark.streaming.dstream
|
Detail
|
|
TransformedDStream
|
Class
|
org.apache.spark.streaming.dstream
|
Detail
|
|
TwitterInputDStream
|
Class
|
org.apache.spark.streaming.twitter
|
Detail
|
|
UnionDStream
|
Class
|
org.apache.spark.streaming.dstream
|
Detail
|
|
WindowedDStream
|
Class
|
org.apache.spark.streaming.dstream
|
Detail
|
