如何解码List的byte [] 到数据集 在火花？

爆炸时，您的结构以“ col”命名。

由于您的Bean类没有“ col”属性，因此失败，并提到了错误。

线程“主要” org.apache.spark.sql.AnalysisException中的异常：在给定输入列的情况下，无法解析“
companyName”：[col];

您可以执行以下选择以使相关列作为普通列：诸如此类：

    Dataset<Row> comapanyListDs = messagesDs.select(explode_outer(col("companyList"))).select(col("col.companyName").as("companyName"),col("col.companyId").as("companyId"));

我还没有测试语法，但是一旦从struct的每一行中获取普通列，都必须立即进行下一步。