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

java.lang.Object
  extended by org.apache.pig.EvalFunc<T>
      extended by org.apache.pig.AccumulatorEvalFunc<T>
          extended by org.apache.pig.AlgebraicEvalFunc<T>
              extended by 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
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
GroovyAlgebraicEvalFunc()
           
GroovyAlgebraicEvalFunc(String path, String namespace, String methodName, String initialMethod, String intermedMethod, String finalMethod)
           
 
Method Summary
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
finish, getArgToFuncMapping, getCacheFiles, getInputSchema, getLogger, getPigLogger, getReporter, getReturnType, getSchemaName, getSchemaType, isAsynchronous, outputSchema, progress, 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


Copyright © 2007-2012 The Apache Software Foundation