如何动态填充数据框的选择子句？给出AnalysisException

您可以尝试以下代码。

从第一个数据集中选择列名称。

List<String> columns = country_df.select("country").where($"data_yr" === 2001).as(Enprers.STRING()).collectAsList();

在第二个数据集中的selectexpr中使用列名。

public static Seq<String> convertListToSeq(List<String> inputList) {        return JavaConverters.asScalaIteratorConverter(inputList.iterator()).asScala().toSeq();}//using selectExprdata_df.selectExpr(convertListToSeq(columns)).show(true);