初识SparkSQL函数,进阶篇(十三)有哪些疑问?
- 内容介绍
- 文章标签
- 相关推荐
本文共计305个文字,预计阅读时间需要2分钟。
1. SparkSQL框架对表结构列的增删改1:使用`withColumn`增加新列`year`,计算`add_time`的年份。
2.新增自增序号列:`df.withColumn(序号, monotonically_increasing_id())`
3.Spark SQL框架对表结构列的增删改2:使用`withColumn`增加新列,列名为`year`,计算`add_time`的年份。
本文共计305个文字,预计阅读时间需要2分钟。
1. SparkSQL框架对表结构列的增删改1:使用`withColumn`增加新列`year`,计算`add_time`的年份。
2.新增自增序号列:`df.withColumn(序号, monotonically_increasing_id())`
3.Spark SQL框架对表结构列的增删改2:使用`withColumn`增加新列,列名为`year`,计算`add_time`的年份。

