in spark/sql/dataframe.go [1705:1718]
func (df *dataFrameImpl) All(ctx context.Context) iter.Seq2[types.Row, error] {
data, err := df.Collect(ctx)
return func(yield func(types.Row, error) bool) {
if err != nil {
yield(nil, err)
return
}
for _, row := range data {
if !yield(row, nil) {
break
}
}
}
}