spark structured streaming和flink
时间: 2023-04-03 16:03:12 浏览: 293
sparkstreaming:封装sparkstreaming动态调节batch time(有数据就执行计算); 支持运行过程中增删topic; 封装sparkstreaming 1.6 - kafka 010 用以支持 SSL
的流处理有什么区别?
C 知道:Spark Structured Streaming 和 Flink 的流处理都是实时数据处理的解决方案,但是它们的实现方式和特点不同。Spark Structured Streaming 基于 Spark SQL 引擎,可以使用 SQL 查询语言进行流处理,支持批处理和流处理的混合模式,但是对于低延迟的数据处理场景不够优秀。Flink 的流处理引擎则专注于低延迟、高吞吐量的数据处理,支持事件时间和处理时间两种时间模型,可以实现更加复杂的流处理逻辑。
阅读全文