org.apache.pig.scripting.groovy

Class GroovyAlgebraicEvalFunc.MapGroovyAlgebraicEvalFunc

java.lang.Object

org.apache.pig.EvalFunc<T>

org.apache.pig.AccumulatorEvalFunc<T>

org.apache.pig.AlgebraicEvalFunc<T>

org.apache.pig.scripting.groovy.GroovyAlgebraicEvalFunc<java.util.Map<java.lang.String,?>>

org.apache.pig.scripting.groovy.GroovyAlgebraicEvalFunc.MapGroovyAlgebraicEvalFunc

All Implemented Interfaces:

Accumulator<java.util.Map<java.lang.String,?>>, Algebraic

Enclosing class:

GroovyAlgebraicEvalFunc<T>

public static class GroovyAlgebraicEvalFunc.MapGroovyAlgebraicEvalFunc
extends GroovyAlgebraicEvalFunc<java.util.Map<java.lang.String,?>>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	GroovyAlgebraicEvalFunc.MapGroovyAlgebraicEvalFunc.Final

Nested classes/interfaces inherited from class org.apache.pig.scripting.groovy.GroovyAlgebraicEvalFunc

GroovyAlgebraicEvalFunc.AlgebraicFunctionWrapper<T>, GroovyAlgebraicEvalFunc.BigDecimalGroovyAlgebraicEvalFunc, GroovyAlgebraicEvalFunc.BigIntegerGroovyAlgebraicEvalFunc, GroovyAlgebraicEvalFunc.BooleanGroovyAlgebraicEvalFunc, GroovyAlgebraicEvalFunc.ChararrayGroovyAlgebraicEvalFunc, GroovyAlgebraicEvalFunc.DataBagGroovyAlgebraicEvalFunc, GroovyAlgebraicEvalFunc.DataByteArrayGroovyAlgebraicEvalFunc, GroovyAlgebraicEvalFunc.DateTimeGroovyAlgebraicEvalFunc, GroovyAlgebraicEvalFunc.DoubleGroovyAlgebraicEvalFunc, GroovyAlgebraicEvalFunc.FloatGroovyAlgebraicEvalFunc, GroovyAlgebraicEvalFunc.Initial, GroovyAlgebraicEvalFunc.IntegerGroovyAlgebraicEvalFunc, GroovyAlgebraicEvalFunc.Intermed, GroovyAlgebraicEvalFunc.LongGroovyAlgebraicEvalFunc, GroovyAlgebraicEvalFunc.MapGroovyAlgebraicEvalFunc, 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
MapGroovyAlgebraicEvalFunc(java.lang.String path, java.lang.String namespace, java.lang.String methodName, java.lang.String initialMethod, java.lang.String intermedMethod, java.lang.String finalMethod)

Method Summary

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

Methods inherited from class org.apache.pig.scripting.groovy.GroovyAlgebraicEvalFunc

getInitial, getIntermed

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

addCredentials, 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

MapGroovyAlgebraicEvalFunc

public MapGroovyAlgebraicEvalFunc(java.lang.String path,
                                  java.lang.String namespace,
                                  java.lang.String methodName,
                                  java.lang.String initialMethod,
                                  java.lang.String intermedMethod,
                                  java.lang.String finalMethod)
                           throws java.io.IOException

Throws:

java.io.IOException

Method Detail

getFinal

public java.lang.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 GroovyAlgebraicEvalFunc<java.util.Map<java.lang.String,?>>

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.