阿里云文档 2024-10-18

表格存储对接 Spark Streaming 场景案例的视频介绍

表格存储对接 Spark Streaming 场景案例的视频介绍

阿里云文档 2024-10-18

表格存储对接 Spark Streaming 的操作示例

表格存储对接 Spark Streaming 的操作示例

阿里云文档 2024-10-18

表格存储对接 Spark Streaming 介绍

表格存储对接 Spark Streaming 介绍

文章 2024-08-15 来自:开发者社区

流计算引擎数据问题之在 Spark Structured Streaming 中水印计算和使用如何解决

问题一:Apache Kafka Streams 的完整性推理过程是怎样的? Apache Kafka Streams 的完整性推理过程是怎样的? 参考回答: Apache Kafka Streams 的完整性推理过程不使用流中嵌入的特殊元信息或系统级低水印时间戳,而是允许通过在每个算子上配置宽限期来进行细粒度的完整性确定。生产阶段,事件流经算子时,算...

流计算引擎数据问题之在 Spark Structured Streaming 中水印计算和使用如何解决
阿里云文档 2024-07-05

如何在Spark Streaming SQL中使用INSERT INTO语句

StarRocks中INSERT INTO语句的使用方式和MySQL等数据库中INSERT INTO语句的使用方式类似, 但在StarRocks中,所有的数据写入都是一个独立的导入作业 ,所以StarRocks中将INSERT INTO作为一种导入方式介绍。本文为您介绍Insert Into导入的使用场景、相关配置以及导入示例。

阿里云文档 2024-07-05

如何通过Spark Structured Streaming流式写入Iceberg表

本文为您介绍如何通过Spark Structured Streaming流式写入Iceberg表。

问答 2024-06-17 来自:开发者社区

在 Spark Structured Streaming 中,水印是如何计算和使用的?

在 Spark Structured Streaming 中,水印是如何计算和使用的?

文章 2023-05-30 来自:开发者社区

Spark Streaming保存计算状态

一、实验目的掌握 DStream数据累加函数updateStateByKey。  掌握 DStream数据累加函数mapWithState。二、实验内容1、每5秒钟计算一次每个单词出现的累加数量。(使用Socket数据源)三、实验原理在DStream中支持跨批次数据执行计算时保持任意状态。在Spark第一代流处理(Spark Streaming)中,这需要手工实现。四、实验环境硬件:x86_64....

问答 2022-05-10 来自:开发者社区

如果 Spark Streaming 存在非确定性的计算,则不能实现端到端一致,原因是什么?

如果 Spark Streaming 存在非确定性的计算,则不能实现端到端一致,原因是什么?

文章 2022-02-16 来自:开发者社区

Spark Streaming场景应用- Spark Streaming计算模型及监控

Spark Streaming是一套优秀的实时计算框架。其良好的可扩展性、高吞吐量以及容错机制能够满足我们很多的场景应用。本篇结合我们的应用场景,介结我们在使用Spark Streaming方面的技术架构,并着重讲解Spark Streaming两种计算模型,无状态和状态计算模型以及该两种模型的注意事项;接着介绍了Spark Streaming在监控方面所做的一些事情,最后总结了Spark St....

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

Apache Spark 中国技术社区

阿里巴巴开源大数据技术团队成立 Apache Spark 中国技术社区,定期推送精彩案例,问答区数个 Spark 技术同学每日在线答疑,只为营造 Spark 技术交流氛围,欢迎加入!

+关注