Structured Streaming《入门示例》

  概述: Structured Streaming 是一个构建在Spark SQL 引擎上,可扩展,容错的的流处理引擎。您能够像编写静态数据的批处理程序同样,编写流处理程序。Spark SQL 引擎会增量的运行流处理程序,并持续的,在有流数据到来时更新最终结果。您可使用DataSet/DataFrame API 来编写流聚合、事件窗口、流和批 join等操做(目前支持Scala,Java,Pyt
相关文章
相关标签/搜索