阿里云文档 2024-07-05

如何使用Spark DataFrame API开发一个流式作业消费LogService数据

本文简单介绍如何使用Spark DataFrame API开发一个流式作业消费LogService数据。

阿里云文档 2024-05-23

SparkSQL、Dataset和DataFrame介绍以及SparkSQL的基础操作

本文为您介绍Spark SQL、Dataset和DataFrame相关的概念,以及Spark SQL的基础操作。

阿里云文档 2022-02-24

如何使用Spark的DataFrame方式访问表格存储

使用Spark的DataFrame方式访问表格存储,并在本地和集群上分别进行运行调试。

问答 2019-01-02 来自:开发者社区

如何计算和获取Spark Dataframe中唯一ID的值总和?

我有以下Dataframe,我希望按ID汇总,并为每个唯一ID总和'value'列:import org.apache.spark.sql.functions._import spark.implicits._// some data...val df = Seq( (1, 2), (1, 4), (1, 1), (2, 2), (2, 2), (3, 2), (3, 1), (...

问答 2018-12-12 来自:开发者社区

计算`Spark Dataframe的连续行上的编辑距离

我有一个数据框如下: import org.apache.spark.sql.expressions.Windowimport org.apache.spark.sql.Columnimport org.apache.spark.sql.functions._import spark.implicits._ // some data...val df = Seq( (1, "AA", "BB".....

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

Apache Spark 中国技术社区

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

+关注
X