All Implemented Interfaces:
Accumulator< DataBag>, Algebraic
public static class
extends JrubyAlgebraicEvalFunc< DataBag>
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. This
is why class specific shells are provided here. This is also the reason why the
Ruby Algebraic interface is the only interface that does not currently allow overriding
outputSchema, and a fixed one must be provided.
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.pig.scripting.jruby.
JrubyAlgebraicEvalFunc JrubyAlgebraicEvalFunc.AlgebraicFunctionWrapper< T>, JrubyAlgebraicEvalFunc.BagJrubyAlgebraicEvalFunc, JrubyAlgebraicEvalFunc.ChararrayJrubyAlgebraicEvalFunc, JrubyAlgebraicEvalFunc.DataByteArrayJrubyAlgebraicEvalFunc, JrubyAlgebraicEvalFunc.DoubleJrubyAlgebraicEvalFunc, JrubyAlgebraicEvalFunc.FloatJrubyAlgebraicEvalFunc, JrubyAlgebraicEvalFunc.Initial, JrubyAlgebraicEvalFunc.IntegerJrubyAlgebraicEvalFunc, JrubyAlgebraicEvalFunc.Intermed, JrubyAlgebraicEvalFunc.LongJrubyAlgebraicEvalFunc, JrubyAlgebraicEvalFunc.MapJrubyAlgebraicEvalFunc, JrubyAlgebraicEvalFunc.TupleJrubyAlgebraicEvalFunc
Modifier and Type
Method and Description
This must be implement as per a normal Algebraic interface.
Methods inherited from class org.apache.pig.
EvalFunc allowCompileTimeCalculation, finish, getArgToFuncMapping, getCacheFiles, getInputSchema, 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
This must be implement as per a normal Algebraic interface. See
getFinal JrubyAlgebraicEvalFunc< DataBag> 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.
Copyright © 2007-2012 The Apache Software Foundation