小编Aks*_*hav的帖子

如何在spark中将多列内爆为一个结构

我有一个具有以下架构的 Spark 数据框:

  • 标头
  • 钥匙
  • ID
  • 时间戳
  • 度量值1
  • 度量值2

我想将多个列组合成一个结构,以便生成的模式变为:

  • 标题(列)
  • 键(列)
  • 值(结构)
    • 编号(列)
    • 时间戳(列)
    • 度量值1(列)
    • 度量值2(列)

我希望它成为这样的格式,以便它适合作为卡夫卡输入。请告诉如何实现这一目标。

apache-spark apache-spark-sql

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

标签 统计

apache-spark ×1

apache-spark-sql ×1