输入DStreams表示从数据源获取的原始数据流。Spark Streaming拥有两类数据源 (1)基本源(Basic sources):这些源在StreamingContext API中直接可用。例如文件系统、套接字连接、 Akka的actor等。 (2)高级源(Advanced sources):这些源包括Kafka,Flume,Kinesis,Twitter等等。 1、基本数据源输入源码

SparkStreaming   基本数据源