public abstract class AlgebraicFloatMathBase extends EvalFunc<T> implements Accumulator<Float>
Modifier and Type | Class and Description |
---|---|
static class |
AlgebraicFloatMathBase.Final |
static class |
AlgebraicFloatMathBase.Intermediate |
static class |
AlgebraicMathBase.Initial |
protected static class |
AlgebraicMathBase.KNOWN_OP |
protected static interface |
AlgebraicMathBase.KnownOpProvider |
EvalFunc.SchemaType
Modifier and Type | Field and Description |
---|---|
protected AlgebraicMathBase.KnownOpProvider |
opProvider |
log, pigLogger, reporter, returnType
Constructor and Description |
---|
AlgebraicFloatMathBase() |
Modifier and Type | Method and Description |
---|---|
void |
accumulate(Tuple b)
Pass tuples to the UDF.
|
void |
cleanup()
Called after getValue() to prepare processing for next key.
|
protected static Float |
doTupleWork(Tuple input,
AlgebraicMathBase.KnownOpProvider opProvider) |
Float |
exec(Tuple input)
This callback method must be implemented by all subclasses.
|
String |
getFinal()
Get the final function.
|
String |
getInitial()
Get the initial function.
|
String |
getIntermed()
Get the intermediate function.
|
protected static Float |
getSeed(AlgebraicMathBase.KNOWN_OP op) |
Float |
getValue()
Called when all tuples from current key have been passed to accumulate.
|
Schema |
outputSchema(Schema input)
Report the schema of the output of this UDF.
|
protected void |
setOp(AlgebraicMathBase.KNOWN_OP op) |
allowCompileTimeCalculation, finish, getArgToFuncMapping, getCacheFiles, getInputSchema, getLoadCaster, getLogger, getPigLogger, getReporter, getReturnType, getSchemaName, getSchemaType, getShipFiles, isAsynchronous, needEndOfAllInputProcessing, progress, setEndOfAllInput, setInputSchema, setPigLogger, setReporter, setUDFContextSignature, warn
protected AlgebraicMathBase.KnownOpProvider opProvider
protected static Float getSeed(AlgebraicMathBase.KNOWN_OP op)
protected static Float doTupleWork(Tuple input, AlgebraicMathBase.KnownOpProvider opProvider) throws ExecException
ExecException
public Float exec(Tuple input) throws IOException
EvalFunc
exec
in class EvalFunc<Float>
input
- the Tuple to be processed.IOException
public Schema outputSchema(Schema input)
EvalFunc
The default implementation interprets the OutputSchema
annotation,
if one is present. Otherwise, it returns null
(no known output schema).
outputSchema
in class EvalFunc<Float>
input
- Schema of the inputpublic void accumulate(Tuple b) throws IOException
Accumulator
accumulate
in interface Accumulator<Float>
b
- A tuple containing a single field, which is a bag. The bag will contain the set
of tuples being passed to the UDF in this iteration.IOException
public void cleanup()
Accumulator
cleanup
in interface Accumulator<Float>
public Float getValue()
Accumulator
getValue
in interface Accumulator<Float>
protected void setOp(AlgebraicMathBase.KNOWN_OP op)
public String getInitial()
Algebraic
getInitial
in interface Algebraic
public String getIntermed()
Algebraic
getIntermed
in interface Algebraic
Copyright © 2007-2017 The Apache Software Foundation