Как добавить функцию с dataType Seq [row] => Seq [row] в dataFrame

Question

пример

def exampleFun : Seq[Row] => Seq[Row]{
some code
}

Как мне добавить это в dataframe или есть способ преобразовать это в тип данных Dataframe => DataFrame

Answer 1

Если вам нужно преобразовать вашу функцию из Seq[Row] => Seq[Row] в DataFrame => DataFrame, вы можете сделать это через dataFrame.flatMap, например:

val func: DataFrame => DataFrame = df => df.flatMap(row => exampleFun(Seq(row)))

Но убедитесь, что вы указали Encoder[Row] неявно иначе он не скомпилируется