Github user cloud-fan commented on a diff in the pull request: https://github.com/apache/spark/pull/21732#discussion_r209130069 --- Diff: sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/encoders/ExpressionEncoder.scala --- @@ -43,20 +43,17 @@ import org.apache.spark.util.Utils * to the name `value`. */ object ExpressionEncoder { - def apply[T : TypeTag](): ExpressionEncoder[T] = { + // Constructs an encoder for top-level row. + def apply[T : TypeTag](): ExpressionEncoder[T] = apply(topLevel = true) + + /** + * @param topLevel whether the encoders to construct are for top-level row. + */ + def apply[T : TypeTag](topLevel: Boolean): ExpressionEncoder[T] = { --- End diff -- where do we call this apply with `topLevel = false`?
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org