3.2.1 输入DStream

文档摘要

3.2.1 输入DStream Spark Streaming 3.2 DStream 操作详解：深入 Input DStream 3.2.1 Input DStream：数据流的入口 Input DStream 正如其名，是数据进入 Spark Streaming 应用的入口。它负责与外部数据源建立连接，并持续不断地接收数据。这些数据源可以是各种各样的，例如：文件系统: 监控目录中的新文件，读取文件内容。网络套接字: 监听 TCP 或 UDP 端口，接收网络数据流。消息队列: 从 Kafka、Flume、Kinesis 等消息系统中消费数据。自定义数据源: 通过自定义 Receiver 或使用 Direct Stream 方式接入各种特殊的数据源。