spark2.2 拆分字符串

原创
2021/05/24 12:20
阅读数 1K

读取文件

val txt = spark.read.text("D:\\tmp\\log.txt")

拆分字符串

val dfSplit:DataFrame = txt.withColumn("split",
  split(col("value"), "\t")).select(
  $"split".getItem(0).as("transactionid"),
  $"split".getItem(1).as("service"),
  $"split".getItem(2).as("appkey")
)
dfSplit.show()
展开阅读全文
加载中
点击引领话题📣 发布并加入讨论🔥
打赏
0 评论
0 收藏
0
分享
返回顶部
顶部