Class UserDefinedAggregateFunc

Object
org.apache.spark.sql.internal.connector.ExpressionWithToString
org.apache.spark.sql.connector.expressions.aggregate.UserDefinedAggregateFunc
All Implemented Interfaces:
Serializable, AggregateFunc, Expression

@Evolving public class UserDefinedAggregateFunc extends org.apache.spark.sql.internal.connector.ExpressionWithToString implements 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.
Since:
3.4.0
See Also:
  • Constructor Details

    • UserDefinedAggregateFunc

      public UserDefinedAggregateFunc(String name, String canonicalName, boolean isDistinct, Expression[] children)
  • Method Details

    • name

      public String name()
    • canonicalName

      public String canonicalName()
    • isDistinct

      public boolean isDistinct()
    • children

      public Expression[] children()
      Description copied from interface: Expression
      Returns an array of the children of this node. Children should not change.
      Specified by:
      children in interface Expression
    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object
    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object