org.apache.spark.sql.hive

Class HiveUdafFunction

Object

org.apache.spark.sql.catalyst.trees.TreeNode<org.apache.spark.sql.catalyst.expressions.Expression>

org.apache.spark.sql.catalyst.expressions.Expression

org.apache.spark.sql.catalyst.expressions.AggregateExpression

org.apache.spark.sql.catalyst.expressions.AggregateFunction

org.apache.spark.sql.hive.HiveUdafFunction

All Implemented Interfaces:

java.io.Serializable, org.apache.spark.sql.catalyst.trees.LeafNode<org.apache.spark.sql.catalyst.expressions.Expression>, HiveInspectors, scala.Equals, scala.Product

public class HiveUdafFunction
extends org.apache.spark.sql.catalyst.expressions.AggregateFunction
implements HiveInspectors, scala.Product, scala.Serializable

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.spark.sql.hive.HiveInspectors

HiveInspectors.typeInfoConversions

Constructor Summary

Constructors

Constructor and Description
HiveUdafFunction()
HiveUdafFunction(HiveFunctionWrapper funcWrapper, scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> exprs, org.apache.spark.sql.catalyst.expressions.AggregateExpression base, boolean isUDAFBridgeRequired)

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.spark.sql.catalyst.expressions.AggregateExpression	base()
Object	eval(org.apache.spark.sql.catalyst.expressions.Row input)
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression>	exprs()
HiveFunctionWrapper	funcWrapper()
org.apache.spark.sql.catalyst.expressions.InterpretedProjection	inputProjection()
boolean	isUDAFBridgeRequired()
void	update(org.apache.spark.sql.catalyst.expressions.Row input)

Methods inherited from class org.apache.spark.sql.catalyst.expressions.AggregateFunction

children, dataType, newInstance, nullable

Methods inherited from class org.apache.spark.sql.catalyst.expressions.AggregateExpression

eval$default$1

Methods inherited from class org.apache.spark.sql.catalyst.expressions.Expression

c2, childrenResolved, f1, f2, foldable, i1, i2, n1, n2, references, resolved

Methods inherited from class org.apache.spark.sql.catalyst.trees.TreeNode

apply, argString, asCode, collect, fastEquals, flatMap, foreach, generateTreeString, getNodeNumbered, makeCopy, map, mapChildren, nodeName, numberedTreeString, otherCopyArgs, simpleString, stringArgs, toString, transform, transformChildrenDown, transformChildrenUp, transformDown, transformUp, treeString, withNewChildren

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.spark.sql.hive.HiveInspectors

inspectorToDataType, javaClassToDataType, toInspector, toInspector, unwrap, wrap, wrap, wrapperFor

Methods inherited from interface scala.Product

productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

HiveUdafFunction

public HiveUdafFunction(HiveFunctionWrapper funcWrapper,
                scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> exprs,
                org.apache.spark.sql.catalyst.expressions.AggregateExpression base,
                boolean isUDAFBridgeRequired)

HiveUdafFunction

public HiveUdafFunction()

Method Detail

funcWrapper

public HiveFunctionWrapper funcWrapper()

exprs

public scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> exprs()

base

public org.apache.spark.sql.catalyst.expressions.AggregateExpression base()

Specified by:

base in class org.apache.spark.sql.catalyst.expressions.AggregateFunction

isUDAFBridgeRequired

public boolean isUDAFBridgeRequired()

eval

public Object eval(org.apache.spark.sql.catalyst.expressions.Row input)

Overrides:

eval in class org.apache.spark.sql.catalyst.expressions.AggregateExpression

inputProjection

public org.apache.spark.sql.catalyst.expressions.InterpretedProjection inputProjection()

update

public void update(org.apache.spark.sql.catalyst.expressions.Row input)

Specified by:

update in class org.apache.spark.sql.catalyst.expressions.AggregateFunction