Spark Structured Streaming + Kafka使用笔记1. 概述3. 解析数据4. 时间窗口5. 输出6. 最后7. Reference
这篇博客将会记录Structured Streaming + Kafka的一些基本使用(Java 版)1. 概述Structured Streaming (结构化流)是一种基于 Spark SQL 引擎构建的可扩展且容错的 stream processing engine (流处理引擎)。可以使用Dataset/DataFrame API 来表示 streaming aggregation...