SparkStreaming之基本数据源输入

输入DStreams表示从数据源获取的原始数据流。Spark Streaming拥有两类数据源
（1）基本源（Basic sources）：这些源在StreamingContext API中直接可用。例如文件系统、套接字连接、

Akka的actor等。
（2）高级源（Advanced sources）：这些源包括Kafka,Flume,Kinesis,Twitter等等。

1、基本数据源输入源码

 

SparkStream 对于外部的数据输入源，一共有下面几种：

（1）用户自定义的数据源：receiverStream

（2）根据TCP协议的数据源： socketTextStream、socketStream

（3）网络数据源：rawSocketStream

（4）hadoop文件系统输入源：fileStream、textFileStream、binaryRecordsStream

 

（5）其他输入源（队列形式的RDD）：queueStream

 

http://blog.csdn.net/legotime/article/details/51836036