Github user marmbrus commented on a diff in the pull request:
https://github.com/apache/spark/pull/4602#discussion_r28371774
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicOperators.scala
---
@@ -40,34 +40,41 @@ case class Project(projectList: Seq[NamedExpression],
child: LogicalPlan) extend
* output of each into a new stream of rows. This operation is similar to
a `flatMap` in functional
* programming with one important additional feature, which allows the
input rows to be joined with
* their output.
+ * @param generator the generator expression
* @param join when true, each output row is implicitly joined with the
input tuple that produced
* it.
* @param outer when true, each input row will be output at least once,
even if the output of the
* given `generator` is empty. `outer` has no effect when
`join` is false.
- * @param alias when set, this string is applied to the schema of the
output of the transformation
- * as a qualifier.
+ * @param child Children logical plan node
+ * @param qualifier Qualifier for the attributes of generator(UDTF)
+ * @param attributeNames the column names for the generator(UDTF), will be
_c0, _c1 .. _cN if
+ * leave as default (empty)
+ * @param gOutput The output of Generator.
*/
case class Generate(
generator: Generator,
join: Boolean,
outer: Boolean,
- alias: Option[String],
- child: LogicalPlan)
+ child: LogicalPlan,
+ qualifier: Option[String] = None,
+ attributeNames: Seq[String] = Nil,
+ gOutput: Seq[Attribute] = Nil)
--- End diff --
Call this: `generatorOutput`
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
