class UserDefinedAggregateFunc extends ExpressionWithToString with AggregateFunc
The general representation of user defined aggregate function, which implements
AggregateFunc
, contains the upper-cased function name, the canonical function name,
the isDistinct
flag and all the inputs. Note that Spark cannot push down aggregate with
this function partially to the source, but can only push down the entire aggregate.
- Annotations
- @Evolving()
- Source
- UserDefinedAggregateFunc.java
- Since
3.4.0
- Alphabetic
- By Inheritance
- UserDefinedAggregateFunc
- AggregateFunc
- ExpressionWithToString
- Serializable
- Expression
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new UserDefinedAggregateFunc(name: String, canonicalName: 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 canonicalName(): String
- 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
- UserDefinedAggregateFunc → 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
- UserDefinedAggregateFunc → AnyRef → Any
- Annotations
- @Override()
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- UserDefinedAggregateFunc → 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 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)