diff options
author | Wenchen Fan <wenchen@databricks.com> | 2017-01-04 12:46:30 +0100 |
---|---|---|
committer | Herman van Hovell <hvanhovell@databricks.com> | 2017-01-04 12:46:30 +0100 |
commit | 101556d0fa704deca0f4a2e5070906d4af2c861b (patch) | |
tree | 4e597be920b0f6ae7247ac486b22a0875f12b5c5 /sql/hive/src | |
parent | fe1c895e16c475a6f271ce600a42a8d0dc7986e5 (diff) | |
download | spark-101556d0fa704deca0f4a2e5070906d4af2c861b.tar.gz spark-101556d0fa704deca0f4a2e5070906d4af2c861b.tar.bz2 spark-101556d0fa704deca0f4a2e5070906d4af2c861b.zip |
[SPARK-19060][SQL] remove the supportsPartial flag in AggregateFunction
## What changes were proposed in this pull request?
Now all aggregation functions support partial aggregate, we can remove the `supportsPartual` flag in `AggregateFunction`
## How was this patch tested?
existing tests.
Author: Wenchen Fan <wenchen@databricks.com>
Closes #16461 from cloud-fan/partial.
Diffstat (limited to 'sql/hive/src')
-rw-r--r-- | sql/hive/src/main/scala/org/apache/spark/sql/hive/hiveUDFs.scala | 2 | ||||
-rw-r--r-- | sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/TestingTypedCount.scala | 2 |
2 files changed, 0 insertions, 4 deletions
diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/hiveUDFs.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/hiveUDFs.scala index fcefd69272..4590197548 100644 --- a/sql/hive/src/main/scala/org/apache/spark/sql/hive/hiveUDFs.scala +++ b/sql/hive/src/main/scala/org/apache/spark/sql/hive/hiveUDFs.scala @@ -380,8 +380,6 @@ private[hive] case class HiveUDAFFunction( override def nullable: Boolean = true - override def supportsPartial: Boolean = true - override lazy val dataType: DataType = inspectorToDataType(returnInspector) override def prettyName: String = name diff --git a/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/TestingTypedCount.scala b/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/TestingTypedCount.scala index aaf1db65a6..31b2430176 100644 --- a/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/TestingTypedCount.scala +++ b/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/TestingTypedCount.scala @@ -42,8 +42,6 @@ case class TestingTypedCount( override def nullable: Boolean = false - override val supportsPartial: Boolean = true - override def createAggregationBuffer(): State = TestingTypedCount.State(0L) override def update(buffer: State, input: InternalRow): State = { |