Package org.apache.cassandra.cql3.functions

Class UDAggregate

java.lang.Object

org.apache.cassandra.cql3.functions.AbstractFunction

org.apache.cassandra.cql3.functions.UserFunction

org.apache.cassandra.cql3.functions.UDAggregate

All Implemented Interfaces:

AssignmentTestable, AggregateFunction, Function, SchemaElement

public class UDAggregate
extends UserFunction
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

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

SchemaElement.SchemaElementType

Field Summary

Fields

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

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

argTypes, name, returnType

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

UNRESOLVED

Fields inherited from interface org.apache.cassandra.cql3.SchemaElement

NAME_COMPARATOR

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	addFunctionsTo(List<Function> functions)
Optional<Difference>	compare(Function function)
static UDAggregate	create(Collection<UDFunction> functions, FunctionName name, List<AbstractType<?>> argTypes, AbstractType<?> returnType, FunctionName stateFunc, FunctionName finalFunc, AbstractType<?> stateType, ByteBuffer initcond)
SchemaElement.SchemaElementType	elementType()	Return the schema element type
boolean	equals(Object o)
ScalarFunction	finalFunction()
int	hashCode()
boolean	hasReferenceTo(Function function)
ByteBuffer	initialCondition()
boolean	isAggregate()	Checks whether the function is an aggregate function or not.
boolean	isPure()	Checks whether the function is a pure function (as in doesn't depend on, nor produces side effects) or not.
AggregateFunction.Aggregate	newAggregate()	Creates a new Aggregate instance.
Arguments	newArguments(ProtocolVersion version)	Creates some new input arguments for this function.
boolean	referencesUserType(ByteBuffer name)
ScalarFunction	stateFunction()
AbstractType<?>	stateType()
String	toCqlString(boolean withInternals, boolean ifNotExists)	Returns a CQL representation of this element
UDAggregate	withUpdatedUserType(Collection<UDFunction> udfs, UserType udt)

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

isNative

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

argTypes, argumentsList, columnName, elementKeyspace, elementName, getCompatibleTypeIfKnown, name, returnType, testAssignment, toCqlString, toString, typesMatch

Methods inherited from class java.lang.Object

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

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

getCompatibleTypeIfKnown, testAssignment

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

argTypes, columnName, isNative, name, returnType

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

elementKeyspace, elementKeyspaceQuotedIfNeeded, elementName, elementNameQuotedIfNeeded

Field Details

logger

protected static final org.slf4j.Logger logger

initcond

protected final ByteBuffer initcond

Constructor Details

UDAggregate

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

Method Details

create

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

isPure

public boolean isPure()

Description copied from interface: Function

Checks whether the function is a pure function (as in doesn't depend on, nor produces side effects) or not.

Specified by:

isPure in interface Function

Returns:

true if the function is a pure function, false otherwise.

newArguments

public Arguments newArguments(ProtocolVersion version)

Description copied from interface: Function

Creates some new input arguments for this function.

Specified by:

newArguments in interface Function

Parameters:

version - the protocol version

Returns:

some new input arguments for this function

hasReferenceTo

public boolean hasReferenceTo(Function function)

referencesUserType

public boolean referencesUserType(ByteBuffer name)

Specified by:

referencesUserType in interface Function

Overrides:

referencesUserType in class AbstractFunction

withUpdatedUserType

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

addFunctionsTo

public void addFunctionsTo(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.

stateFunction

public ScalarFunction stateFunction()

finalFunction

public ScalarFunction finalFunction()

initialCondition

public 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(Object o)

Overrides:

equals in class AbstractFunction

compare

public Optional<Difference> compare(Function function)

Specified by:

compare in interface Function

hashCode

public int hashCode()

Overrides:

hashCode in class AbstractFunction

elementType

public SchemaElement.SchemaElementType elementType()

Description copied from interface: SchemaElement

Return the schema element type

Specified by:

elementType in interface SchemaElement

Returns:

the schema element type

toCqlString

public String toCqlString(boolean withInternals,
 boolean ifNotExists)

Description copied from interface: SchemaElement

Returns a CQL representation of this element

Specified by:

toCqlString in interface SchemaElement

Parameters:

withInternals - if the internals part of the CQL should be exposed.

ifNotExists - if "IF NOT EXISTS" should be included.

Returns:

a CQL representation of this element