org.apache.cassandra.cql3.functions

Class UDAggregate

java.lang.Object

org.apache.cassandra.cql3.functions.AbstractFunction

org.apache.cassandra.cql3.functions.UDAggregate

All Implemented Interfaces:

AssignmentTestable, AggregateFunction, Function

public class UDAggregate
extends AbstractFunction
implements AggregateFunction

Base class for user-defined-aggregates.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.cassandra.cql3.functions.AggregateFunction

AggregateFunction.Aggregate

Nested classes/interfaces inherited from interface org.apache.cassandra.cql3.AssignmentTestable

AssignmentTestable.TestResult

Field Summary

Fields

Modifier and Type	Field and Description
protected java.nio.ByteBuffer	initcond
protected static org.slf4j.Logger	logger

Fields inherited from class org.apache.cassandra.cql3.functions.AbstractFunction

argTypes, name, returnType

Constructor Summary

Constructors

Constructor and Description
UDAggregate(FunctionName name, java.util.List<AbstractType<?>> argTypes, AbstractType<?> returnType, ScalarFunction stateFunc, ScalarFunction finalFunc, java.nio.ByteBuffer initcond)

Method Summary

Modifier and Type	Method and Description
void	addFunctionsTo(java.util.List<Function> functions)
java.util.Optional<Difference>	compare(Function function)
static UDAggregate	create(java.util.Collection<UDFunction> functions, FunctionName name, java.util.List<AbstractType<?>> argTypes, AbstractType<?> returnType, FunctionName stateFunc, FunctionName finalFunc, AbstractType<?> stateType, java.nio.ByteBuffer initcond)
boolean	equals(java.lang.Object o)
ScalarFunction	finalFunction()
int	hashCode()
boolean	hasReferenceTo(Function function)
java.nio.ByteBuffer	initialCondition()
boolean	isAggregate() Checks whether the function is an aggregate function or not.
boolean	isNative() Checks whether the function is a native/hard coded one or not.
AggregateFunction.Aggregate	newAggregate() Creates a new Aggregate instance.
boolean	referencesUserType(java.nio.ByteBuffer name)
ScalarFunction	stateFunction()
AbstractType<?>	stateType()
UDAggregate	withUpdatedUserType(java.util.Collection<UDFunction> udfs, UserType udt)

Methods inherited from class org.apache.cassandra.cql3.functions.AbstractFunction

argTypes, argumentsList, columnName, name, returnType, testAssignment, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.cassandra.cql3.functions.Function

argTypes, columnName, name, returnType

Methods inherited from interface org.apache.cassandra.cql3.AssignmentTestable

testAssignment

Field Detail

logger

protected static final org.slf4j.Logger logger

initcond

protected final java.nio.ByteBuffer initcond

Constructor Detail

UDAggregate

public UDAggregate(FunctionName name,
                   java.util.List<AbstractType<?>> argTypes,
                   AbstractType<?> returnType,
                   ScalarFunction stateFunc,
                   ScalarFunction finalFunc,
                   java.nio.ByteBuffer initcond)

Method Detail

create

public static UDAggregate create(java.util.Collection<UDFunction> functions,
                                 FunctionName name,
                                 java.util.List<AbstractType<?>> argTypes,
                                 AbstractType<?> returnType,
                                 FunctionName stateFunc,
                                 FunctionName finalFunc,
                                 AbstractType<?> stateType,
                                 java.nio.ByteBuffer initcond)

hasReferenceTo

public boolean hasReferenceTo(Function function)

referencesUserType

public boolean referencesUserType(java.nio.ByteBuffer name)

Specified by:

referencesUserType in interface Function

Overrides:

referencesUserType in class AbstractFunction

withUpdatedUserType

public UDAggregate withUpdatedUserType(java.util.Collection<UDFunction> udfs,
                                       UserType udt)

addFunctionsTo

public void addFunctionsTo(java.util.List<Function> functions)

Specified by:

addFunctionsTo in interface Function

Overrides:

addFunctionsTo in class AbstractFunction

isAggregate

public boolean isAggregate()

Description copied from interface: Function

Checks whether the function is an aggregate function or not.

Specified by:

isAggregate in interface Function

Returns:

true if the function is an aggregate function, false otherwise.

isNative

public boolean isNative()

Description copied from interface: Function

Checks whether the function is a native/hard coded one or not.

Specified by:

isNative in interface Function

Returns:

true if the function is a native/hard coded one, false otherwise.

stateFunction

public ScalarFunction stateFunction()

finalFunction

public ScalarFunction finalFunction()

initialCondition

public java.nio.ByteBuffer initialCondition()

stateType

public AbstractType<?> stateType()

newAggregate

public AggregateFunction.Aggregate newAggregate()
                                         throws InvalidRequestException

Description copied from interface: AggregateFunction

Creates a new Aggregate instance.

Specified by:

newAggregate in interface AggregateFunction

Returns:

a new Aggregate instance.

Throws:

InvalidRequestException

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class AbstractFunction

compare

public java.util.Optional<Difference> compare(Function function)

Specified by:

compare in interface Function

hashCode

public int hashCode()

Overrides:

hashCode in class AbstractFunction