Package org.apache.cassandra.cql3.functions

Class JavaUDF

java.lang.Object

org.apache.cassandra.cql3.functions.JavaUDF

public abstract class JavaUDF
extends Object

Base class for all Java UDFs. Used to separate internal classes like UDFunction from user provided code. Only references to this class (and generated implementations) are allowed - references from this class back to C* code are not allowed (except argument/return type information).

Field Summary

Fields

Modifier and Type	Field	Description
protected final UDFContext	udfContext

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	JavaUDF(UDFDataType returnType, UDFContext udfContext)

Method Summary

Modifier and Type	Method	Description
protected final ByteBuffer	decompose(ProtocolVersion protocolVersion, byte value)
protected final ByteBuffer	decompose(ProtocolVersion protocolVersion, double value)
protected final ByteBuffer	decompose(ProtocolVersion protocolVersion, float value)
protected final ByteBuffer	decompose(ProtocolVersion protocolVersion, int value)
protected final ByteBuffer	decompose(ProtocolVersion protocolVersion, long value)
protected final ByteBuffer	decompose(ProtocolVersion protocolVersion, short value)
protected final ByteBuffer	decompose(ProtocolVersion protocolVersion, Object value)
protected abstract Object	executeAggregateImpl(Object state, Arguments arguments)
protected abstract ByteBuffer	executeImpl(Arguments arguments)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

udfContext

protected final UDFContext udfContext

Constructor Details

JavaUDF

protected JavaUDF(UDFDataType returnType,
 UDFContext udfContext)

Method Details

executeImpl

protected abstract ByteBuffer executeImpl(Arguments arguments)

executeAggregateImpl

protected abstract Object executeAggregateImpl(Object state,
 Arguments arguments)

decompose

protected final ByteBuffer decompose(ProtocolVersion protocolVersion,
 Object value)

decompose

protected final ByteBuffer decompose(ProtocolVersion protocolVersion,
 byte value)

decompose

protected final ByteBuffer decompose(ProtocolVersion protocolVersion,
 short value)

decompose

protected final ByteBuffer decompose(ProtocolVersion protocolVersion,
 int value)

decompose

protected final ByteBuffer decompose(ProtocolVersion protocolVersion,
 long value)

decompose

protected final ByteBuffer decompose(ProtocolVersion protocolVersion,
 float value)

decompose

protected final ByteBuffer decompose(ProtocolVersion protocolVersion,
 double value)