自定義Spark Streaming的Receivers

Spark Streaming除了可使用內置的接收器(Receivers,好比Flume、Kafka、Kinesis、files和sockets等)來接收流數據,還能夠自定義接收器來從任意的流中接收數據。開發者們能夠本身實現org.apache.spark.streaming.receiver.Receiver類來從其餘的數據源中接收數據。本文將介紹如何實現自定義接收器,而且在Spark Stre
相關文章
相關標籤/搜索