final class GeneralAggregateFunc extends ExpressionWithToString with AggregateFunc
The general implementation of AggregateFunc, which contains the upper-cased function
name, the isDistinct flag and all the inputs. Note that Spark cannot push down partial
aggregate with this function to the source, but can only push down the entire aggregate.
The currently supported SQL aggregate functions:
-
VAR_POP(input1)
Since 3.3.0 -
VAR_SAMP(input1)
Since 3.3.0 -
STDDEV_POP(input1)
Since 3.3.0 -
STDDEV_SAMP(input1)
Since 3.3.0 -
COVAR_POP(input1, input2)
Since 3.3.0 -
COVAR_SAMP(input1, input2)
Since 3.3.0 -
CORR(input1, input2)
Since 3.3.0 -
REGR_INTERCEPT(input1, input2)
Since 3.4.0 -
REGR_R2(input1, input2)
Since 3.4.0 -
REGR_SLOPE(input1, input2)
Since 3.4.0 -
REGR_SXY(input1, input2)
Since 3.4.0 -
MODE() WITHIN (ORDER BY input1 [ASC|DESC])
Since 4.0.0 -
PERCENTILE_CONT(input1) WITHIN (ORDER BY input2 [ASC|DESC])
Since 4.0.0 -
PERCENTILE_DISC(input1) WITHIN (ORDER BY input2 [ASC|DESC])
Since 4.0.0
- Annotations
- @Evolving()
- Source
- GeneralAggregateFunc.java
- Since
3.3.0
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- GeneralAggregateFunc
- AggregateFunc
- ExpressionWithToString
- Serializable
- Expression
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new GeneralAggregateFunc(name: String, isDistinct: Boolean, children: Array[Expression], orderingWithinGroups: Array[SortValue])
- new GeneralAggregateFunc(name: String, isDistinct: Boolean, children: Array[Expression])
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def children(): Array[Expression]
Returns an array of the children of this node.
Returns an array of the children of this node. Children should not change.
- Definition Classes
- GeneralAggregateFunc → Expression
- Annotations
- @Override()
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- def describe(): String
Format the expression as a human readable SQL-like string.
Format the expression as a human readable SQL-like string.
- Definition Classes
- Expression
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(o: AnyRef): Boolean
- Definition Classes
- GeneralAggregateFunc → AnyRef → Any
- Annotations
- @Override()
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- GeneralAggregateFunc → AnyRef → Any
- Annotations
- @Override()
- def isDistinct(): Boolean
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def name(): String
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def orderingWithinGroups(): Array[SortValue]
- def references(): Array[NamedReference]
List of fields or columns that are referenced by this expression.
List of fields or columns that are referenced by this expression.
- Definition Classes
- Expression
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- ExpressionWithToString → AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)