Github user WeichenXu123 commented on a diff in the pull request:
https://github.com/apache/spark/pull/19156#discussion_r149956415
--- Diff: mllib/src/main/scala/org/apache/spark/ml/stat/Summarizer.scala ---
@@ -527,27 +570,28 @@ private[ml] object SummaryBuilderImpl extends Logging
{
weightExpr: Expression,
mutableAggBufferOffset: Int,
inputAggBufferOffset: Int)
- extends TypedImperativeAggregate[SummarizerBuffer] {
+ extends TypedImperativeAggregate[SummarizerBuffer] with
ImplicitCastInputTypes {
- override def eval(state: SummarizerBuffer): InternalRow = {
+ override def eval(state: SummarizerBuffer): Any = {
--- End diff --
Both of them works, but other similar aggregate function also use `Any`.
Will it cause some issues ?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
