foreach
не вернет ничего, он используется для выполнения действий, основанных на каждой строке кадра данных. Вы должны использовать .map
, который будет возвращать измененный фрейм данных, который вы можете объединить с другим df, имеющим ту же схему.
val tt1 = df.map(action(_))
val df = tt1.union(tt2)