Skip to content

Commit

Permalink
Change implicits ordering in explode functions
Browse files Browse the repository at this point in the history
  • Loading branch information
pomadchin committed Nov 11, 2021
1 parent 48f04a2 commit 375dcc4
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions dataset/src/main/scala/frameless/TypedDataset.scala
Original file line number Diff line number Diff line change
Expand Up @@ -1195,8 +1195,8 @@ class TypedDataset[T] protected[frameless](val dataset: Dataset[T])(implicit val
i6: Tupler.Aux[OutModValues, Out],
i7: TypedEncoder[Out]
): TypedDataset[Out] = {
val df = dataset.toDF()
import org.apache.spark.sql.functions.{explode => sparkExplode}
val df = dataset.toDF()

val trans =
df
Expand Down Expand Up @@ -1231,8 +1231,8 @@ class TypedDataset[T] protected[frameless](val dataset: Dataset[T])(implicit val
i6: Tupler.Aux[OutModValues, Out],
i7: TypedEncoder[Out]
): TypedDataset[Out] = {
val df = dataset.toDF()
import org.apache.spark.sql.functions.{explode => sparkExplode, struct => sparkStruct, col => sparkCol}
val df = dataset.toDF()

// preserve the original list of columns
val columns = df.columns.toSeq.map(sparkCol)
Expand Down

0 comments on commit 375dcc4

Please sign in to comment.