将所有列添加到顶层结构应提供预期的输出。在Scala中：
import org.apache.spark.sql.functions._data.select(struct(data.columns:_*).as("txn_summary"))在Java中，我怀疑是这样的：
import org.apache.spark.sql.functions.struct;data.select(struct(data.columns()).as("txn_summary"));
将所有列添加到顶层结构应提供预期的输出。在Scala中：
import org.apache.spark.sql.functions._data.select(struct(data.columns:_*).as("txn_summary"))在Java中，我怀疑是这样的：
import org.apache.spark.sql.functions.struct;data.select(struct(data.columns()).as("txn_summary"));名师互学网 版权所有 (c)2021-2022 ICP备案号：晋ICP备2021003244-6号
