Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/21611#discussion_r197997909
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/encoders/ExpressionEncoder.scala
---
@@ -43,12 +43,17 @@ import org.apache.spark.util.Utils
* to the name `value`.
*/
object ExpressionEncoder {
- def apply[T : TypeTag](): ExpressionEncoder[T] = {
+ 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 --
who will call this method with `topLevel=false`?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
