将DataFrame中的一列拆分为多列,示例如下:
import sparkObject.spark.implicits._
import org.apache.spark.sql.functions.split
df.withColumn("_tmp", split($"columnToSplit", "\\.")).select(
$"_tmp".getItem(0).as("col1"), $"_tmp".getItem(1).as("col2"),
$"_tmp".getItem(2).as("col3")
)
网友评论