[
https://issues.apache.org/jira/browse/SPARK-16906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apache Spark reassigned SPARK-16906:
------------------------------------
Assignee: Apache Spark
> Adds more input type information for TypedAggregateExpression
> -------------------------------------------------------------
>
> Key: SPARK-16906
> URL: https://issues.apache.org/jira/browse/SPARK-16906
> Project: Spark
> Issue Type: Bug
> Reporter: Sean Zhong
> Assignee: Apache Spark
> Priority: Minor
>
> For TypedAggregateExpression
> {code}
> case class TypedAggregateExpression(
> aggregator: Aggregator[Any, Any, Any],
> inputDeserializer: Option[Expression],
> bufferSerializer: Seq[NamedExpression],
> bufferDeserializer: Expression,
> outputSerializer: Seq[Expression],
> outputExternalType: DataType,
> dataType: DataType,
> nullable: Boolean) extends DeclarativeAggregate with NonSQLExpression
> {code}
> Aggregator of TypedAggregateExpression usually contains a closure like:
> {code}
> class TypedSumDouble[IN](f: IN => Double) extends Aggregator[IN, Double,
> Double]
> {code}
> It will be great if we can add more info in TypedAggregateExpression to
> describe the closure input type {{IN}}, like class, and schema, so that we
> can use this info to make customized optimization like SPARK-14083
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org
For additional commands, e-mail: issues-h...@spark.apache.org
