org.apache.pig.scripting.groovy

Class GroovyAlgebraicEvalFunc<T>

java.lang.Object

org.apache.pig.EvalFunc<T>

org.apache.pig.AccumulatorEvalFunc<T>

org.apache.pig.AlgebraicEvalFunc<T>

org.apache.pig.scripting.groovy.GroovyAlgebraicEvalFunc<T>

All Implemented Interfaces:

Accumulator<T>, Algebraic

Direct Known Subclasses:

GroovyAlgebraicEvalFunc.BigDecimalGroovyAlgebraicEvalFunc, GroovyAlgebraicEvalFunc.BigIntegerGroovyAlgebraicEvalFunc, GroovyAlgebraicEvalFunc.BooleanGroovyAlgebraicEvalFunc, GroovyAlgebraicEvalFunc.ChararrayGroovyAlgebraicEvalFunc, GroovyAlgebraicEvalFunc.DataBagGroovyAlgebraicEvalFunc, GroovyAlgebraicEvalFunc.DataByteArrayGroovyAlgebraicEvalFunc, GroovyAlgebraicEvalFunc.DateTimeGroovyAlgebraicEvalFunc, GroovyAlgebraicEvalFunc.DoubleGroovyAlgebraicEvalFunc, GroovyAlgebraicEvalFunc.FloatGroovyAlgebraicEvalFunc, GroovyAlgebraicEvalFunc.IntegerGroovyAlgebraicEvalFunc, GroovyAlgebraicEvalFunc.LongGroovyAlgebraicEvalFunc, GroovyAlgebraicEvalFunc.MapGroovyAlgebraicEvalFunc, GroovyAlgebraicEvalFunc.TupleGroovyAlgebraicEvalFunc

public abstract class GroovyAlgebraicEvalFunc<T>
extends AlgebraicEvalFunc<T>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	GroovyAlgebraicEvalFunc.AlgebraicFunctionWrapper<T>
static class	GroovyAlgebraicEvalFunc.BigDecimalGroovyAlgebraicEvalFunc
static class	GroovyAlgebraicEvalFunc.BigIntegerGroovyAlgebraicEvalFunc
static class	GroovyAlgebraicEvalFunc.BooleanGroovyAlgebraicEvalFunc
static class	GroovyAlgebraicEvalFunc.ChararrayGroovyAlgebraicEvalFunc
static class	GroovyAlgebraicEvalFunc.DataBagGroovyAlgebraicEvalFunc Unlike EvalFuncs and Accumulators, the type must be known at compile time (ie it can't return Object), as Pig inspects the type and ensures that it is valid.
static class	GroovyAlgebraicEvalFunc.DataByteArrayGroovyAlgebraicEvalFunc
static class	GroovyAlgebraicEvalFunc.DateTimeGroovyAlgebraicEvalFunc
static class	GroovyAlgebraicEvalFunc.DoubleGroovyAlgebraicEvalFunc
static class	GroovyAlgebraicEvalFunc.Final<T>
static class	GroovyAlgebraicEvalFunc.FloatGroovyAlgebraicEvalFunc
static class	GroovyAlgebraicEvalFunc.Initial
static class	GroovyAlgebraicEvalFunc.IntegerGroovyAlgebraicEvalFunc
static class	GroovyAlgebraicEvalFunc.Intermed
static class	GroovyAlgebraicEvalFunc.LongGroovyAlgebraicEvalFunc
static class	GroovyAlgebraicEvalFunc.MapGroovyAlgebraicEvalFunc
static class	GroovyAlgebraicEvalFunc.TupleGroovyAlgebraicEvalFunc

Nested classes/interfaces inherited from class org.apache.pig.EvalFunc

EvalFunc.SchemaType

Field Summary

Fields inherited from class org.apache.pig.EvalFunc

log, pigLogger, reporter, returnType

Constructor Summary

Constructors

Constructor and Description
GroovyAlgebraicEvalFunc()
GroovyAlgebraicEvalFunc(String path, String namespace, String methodName, String initialMethod, String intermedMethod, String finalMethod)

Method Summary

Modifier and Type	Method and Description
abstract String	getFinal() This must be implement as per a normal Algebraic interface.
String	getInitial() This must be implement as per a normal Algebraic interface.
String	getIntermed() This must be implement as per a normal Algebraic interface.

Methods inherited from class org.apache.pig.AlgebraicEvalFunc

accumulate, cleanup, getValue

Methods inherited from class org.apache.pig.AccumulatorEvalFunc

exec

Methods inherited from class org.apache.pig.EvalFunc

allowCompileTimeCalculation, finish, getArgToFuncMapping, getCacheFiles, getInputSchema, getLoadCaster, getLogger, getPigLogger, getReporter, getReturnType, getSchemaName, getSchemaType, getShipFiles, isAsynchronous, needEndOfAllInputProcessing, outputSchema, progress, setEndOfAllInput, setInputSchema, setPigLogger, setReporter, setUDFContextSignature, warn

Methods inherited from class java.lang.Object

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

Constructor Detail

GroovyAlgebraicEvalFunc

public GroovyAlgebraicEvalFunc()

GroovyAlgebraicEvalFunc

public GroovyAlgebraicEvalFunc(String path,
                               String namespace,
                               String methodName,
                               String initialMethod,
                               String intermedMethod,
                               String finalMethod)

Method Detail

getFinal

public abstract String getFinal()

Description copied from class: AlgebraicEvalFunc

This must be implement as per a normal Algebraic interface. See Algebraic for more information.

Specified by:

getFinal in interface Algebraic

Specified by:

getFinal in class AlgebraicEvalFunc<T>

Returns:

A function name of f_final. f_final should be an eval func parametrized by the same datum as the eval func implementing this interface.

getInitial

public String getInitial()

Description copied from class: AlgebraicEvalFunc

This must be implement as per a normal Algebraic interface. See Algebraic for more information.

Specified by:

getInitial in interface Algebraic

Specified by:

getInitial in class AlgebraicEvalFunc<T>

Returns:

A function name of f_init. f_init should be an eval func. The return type of f_init.exec() has to be Tuple

getIntermed

public String getIntermed()

Description copied from class: AlgebraicEvalFunc

This must be implement as per a normal Algebraic interface. See Algebraic for more information.

Specified by:

getIntermed in interface Algebraic

Specified by:

getIntermed in class AlgebraicEvalFunc<T>

Returns:

A function name of f_intermed. f_intermed should be an eval func. The return type of f_intermed.exec() has to be Tuple