Spark2.0 Structured Streaming

综述 Structured Streaming是构建在Spark SQL引擎上的流式数据处理引擎,使用Scala编写,具备容错功能。你能够像在使用静态RDD数据同样来编写你的流式计算过程。当流数据接二连三的产生时,Spark SQL将会增量的,持续不断的处理这些数据并将结果更新到结果集中。你可使用DataSet/DataFrame API来展示数据流的aggregations, event-tim
相关文章
相关标签/搜索