85、Spark Streaming之輸入DStream和Receiver詳解

輸入DStream和Receiver詳解 輸入DStream代表了來自數據源的輸入數據流。在之前的wordcount例子中，lines就是一個輸入DStream（JavaReceiverInputDStream），代表了從netcat（nc）服務接收到的數據流。除了文件數據流之外，所有的輸入DStream都會綁定一個Receiver對象，該對象是一個關鍵的組件，用來從數據源接收數據，並將其存儲在S

>>阅读原文<<