读取文件
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()