Spark DataFrame не разрешает множественный динамический список столбцов с функцией окна в группе по

Question

sample code:- 
val list=Seq("symbol").map(column=>col(column))
    val windowedCount = stockDs
      .withWatermark("time", "500 milliseconds")
      .groupBy( list:_*,
        window($"time", "10 seconds")
      )
      .sum("value")

`Ошибка: _ * 'здесь разрешена аннотация (такие аннотации допускаются только в аргументах * -параметров).

Answer 1

groupBy подпись

 def groupBy(cols: Column*): RelationalGroupedDataset 

Таким образом, вы можете предоставить только один аргумент последовательности:

stockDs
  ...
  .groupBy(list :+ window($"time", "10 seconds"): _*)