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:
-
Field Summary
Fields inherited from interface org.apache.spark.sql.connector.expressions.Expression
EMPTY_EXPRESSION, EMPTY_NAMED_REFERENCE
-
Constructor Summary
ConstructorDescriptionUserDefinedAggregateFunc
(String name, String canonicalName, boolean isDistinct, Expression[] children) -
Method Summary
Methods inherited from class org.apache.spark.sql.internal.connector.ExpressionWithToString
describe, references, toString
Methods inherited from interface org.apache.spark.sql.connector.expressions.Expression
describe, references
-
Constructor Details
-
UserDefinedAggregateFunc
public UserDefinedAggregateFunc(String name, String canonicalName, boolean isDistinct, Expression[] children)
-
-
Method Details
-
name
-
canonicalName
-
isDistinct
public boolean isDistinct() -
children
Description copied from interface:Expression
Returns an array of the children of this node. Children should not change.- Specified by:
children
in interfaceExpression
-
equals
-
hashCode
public int hashCode()
-