Skip to content

Latest commit

 

History

History

bigdata-spark-streaming

Folders and files

NameName
Last commit message
Last commit date

parent directory

..
 
 
 
 
 
 
 
 
spark streaming
spark streaming基本原理为将输入数据流以时间片为单位进行拆分,然后以批处理的方式处理每个时间片的数据。

实时数据流

数据流处理

Spark Streaming使用DSTream来表示一个连续的数据流。
DSTream被表示为一系列连续的RDDs,其中每个RDD包含来自一定时间间隔的数据。