小编Kum*_*123的帖子

向Spark数据框中的列添加常量值

我有一个Spark数据框,如下所示

id person age
1  naveen 24
Run Code Online (Sandbox Code Playgroud)

我想为每个列值添加一个常量"del",除了数据框中的最后一列,如下所示,

id   person   age
1del naveendel 24
Run Code Online (Sandbox Code Playgroud)

有人可以帮助我如何使用Scala在Spark df中实现它

scala apache-spark apache-spark-sql

2
推荐指数
1
解决办法
6765
查看次数

基于列值迭代Spark Dataframe

我在Spark中有一个带有以下数据的数据框

{ID:"1",CNT:"2", Age:"21", Class:"3"}   
{ID:"2",CNT:"3", Age:"24", Class:"5"}
Run Code Online (Sandbox Code Playgroud)

我想基于CNT值迭代数据框并生成如下输出:

{ID:"1",CNT:"1", Age:"21", Class:"3"}  
{ID:"1",CNT:"2", Age:"21", Class:"3"}  
{ID:"2",CNT:"1", Age:"24", Class:"5"}  
{ID:"2",CNT:"2", Age:"24", Class:"5"}  
{ID:"2",CNT:"3", Age:"24", Class:"5"}
Run Code Online (Sandbox Code Playgroud)

有人可以知道如何实现这一目标.

scala apache-spark apache-spark-sql

1
推荐指数
1
解决办法
1958
查看次数

标签 统计

apache-spark ×2

apache-spark-sql ×2

scala ×2