datafu.pig.stats

Class DoubleVAR

java.lang.Object

org.apache.pig.EvalFunc<java.lang.Double>

datafu.pig.stats.DoubleVAR

All Implemented Interfaces:

org.apache.pig.Accumulator<java.lang.Double>, org.apache.pig.Algebraic

public class DoubleVAR
extends org.apache.pig.EvalFunc<java.lang.Double>
implements org.apache.pig.Algebraic, org.apache.pig.Accumulator<java.lang.Double>

Use VAR

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DoubleVAR.Final
static class	DoubleVAR.Initial
static class	DoubleVAR.Intermediate

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

org.apache.pig.EvalFunc.SchemaType

Field Summary

Fields inherited from class org.apache.pig.EvalFunc

log, pigLogger, reporter, returnType

Constructor Summary

Constructors

Constructor and Description
DoubleVAR()

Method Summary

Modifier and Type	Method and Description
void	accumulate(org.apache.pig.data.Tuple b)
void	cleanup()
protected static org.apache.pig.data.Tuple	combine(org.apache.pig.data.DataBag values)
protected static long	count(org.apache.pig.data.Tuple input)
java.lang.Double	exec(org.apache.pig.data.Tuple input)
java.lang.String	getFinal()
java.lang.String	getInitial()
java.lang.String	getIntermed()
java.lang.Double	getValue()
org.apache.pig.impl.logicalLayer.schema.Schema	outputSchema(org.apache.pig.impl.logicalLayer.schema.Schema input)
protected static java.lang.Double	sum(org.apache.pig.data.Tuple input)
protected static java.lang.Double	sumSquare(org.apache.pig.data.Tuple input)

Methods inherited from class org.apache.pig.EvalFunc

allowCompileTimeCalculation, finish, getArgToFuncMapping, getCacheFiles, getInputSchema, getLogger, getPigLogger, getReporter, getReturnType, getSchemaName, getSchemaType, getShipFiles, isAsynchronous, 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

DoubleVAR

public DoubleVAR()

Method Detail

exec

public java.lang.Double exec(org.apache.pig.data.Tuple input)
                      throws java.io.IOException

Specified by:

exec in class org.apache.pig.EvalFunc<java.lang.Double>

Throws:

java.io.IOException

getInitial

public java.lang.String getInitial()

Specified by:

getInitial in interface org.apache.pig.Algebraic

getIntermed

public java.lang.String getIntermed()

Specified by:

getIntermed in interface org.apache.pig.Algebraic

getFinal

public java.lang.String getFinal()

Specified by:

getFinal in interface org.apache.pig.Algebraic

combine

protected static org.apache.pig.data.Tuple combine(org.apache.pig.data.DataBag values)
                                            throws org.apache.pig.backend.executionengine.ExecException

Throws:

org.apache.pig.backend.executionengine.ExecException

count

protected static long count(org.apache.pig.data.Tuple input)
                     throws org.apache.pig.backend.executionengine.ExecException

Throws:

org.apache.pig.backend.executionengine.ExecException

sum

protected static java.lang.Double sum(org.apache.pig.data.Tuple input)
                               throws org.apache.pig.backend.executionengine.ExecException,
                                      java.io.IOException

Throws:

org.apache.pig.backend.executionengine.ExecException

java.io.IOException

sumSquare

protected static java.lang.Double sumSquare(org.apache.pig.data.Tuple input)
                                     throws org.apache.pig.backend.executionengine.ExecException,
                                            java.io.IOException

Throws:

org.apache.pig.backend.executionengine.ExecException

java.io.IOException

outputSchema

public org.apache.pig.impl.logicalLayer.schema.Schema outputSchema(org.apache.pig.impl.logicalLayer.schema.Schema input)

Overrides:

outputSchema in class org.apache.pig.EvalFunc<java.lang.Double>

accumulate

public void accumulate(org.apache.pig.data.Tuple b)
                throws java.io.IOException

Specified by:

accumulate in interface org.apache.pig.Accumulator<java.lang.Double>

Throws:

java.io.IOException

cleanup

public void cleanup()

Specified by:

cleanup in interface org.apache.pig.Accumulator<java.lang.Double>

getValue

public java.lang.Double getValue()

Specified by:

getValue in interface org.apache.pig.Accumulator<java.lang.Double>