StreamSource 是指采用SparkStreaming 的架构，从消息系统（流式）中连续消费消息，并通过DataFlow设计的运算方式，连续不断的处理消息（Transformer），然后持久化消息。