org.apache.datasketches.pig.tuple

Class UnionArrayOfDoublesSketch

java.lang.Object

org.apache.pig.EvalFunc<org.apache.pig.data.Tuple>

org.apache.datasketches.pig.tuple.UnionArrayOfDoublesSketch

All Implemented Interfaces:

org.apache.pig.Accumulator<org.apache.pig.data.Tuple>, org.apache.pig.Algebraic

public class UnionArrayOfDoublesSketch
extends org.apache.pig.EvalFunc<org.apache.pig.data.Tuple>
implements org.apache.pig.Algebraic

This is to union ArrayOfDoublesSketches. It supports all three ways: exec(), Accumulator and Algebraic

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	UnionArrayOfDoublesSketch.Initial
static class	UnionArrayOfDoublesSketch.IntermediateFinal

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
UnionArrayOfDoublesSketch() Constructor with default sketch size and default number of values of 1.
UnionArrayOfDoublesSketch(String numValues) Constructor with default sketch size and given number of values.
UnionArrayOfDoublesSketch(String sketchSize, String numValues) Constructor with given sketch size and vumber of values.

Method Summary

Modifier and Type	Method and Description
void	accumulate(org.apache.pig.data.Tuple inputTuple)
void	cleanup()
org.apache.pig.data.Tuple	exec(org.apache.pig.data.Tuple inputTuple)
String	getFinal()
String	getInitial()
String	getIntermed()
org.apache.pig.data.Tuple	getValue()

Methods inherited from class org.apache.pig.EvalFunc

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

UnionArrayOfDoublesSketch

public UnionArrayOfDoublesSketch()

Constructor with default sketch size and default number of values of 1.

UnionArrayOfDoublesSketch

public UnionArrayOfDoublesSketch(String numValues)

Constructor with default sketch size and given number of values.

Parameters:

numValues - String representation of number of values per key

UnionArrayOfDoublesSketch

public UnionArrayOfDoublesSketch(String sketchSize,
                                 String numValues)

Constructor with given sketch size and vumber of values.

Parameters:

sketchSize - String representation of sketch size

numValues - String representation of number of values per key

Method Detail

getInitial

public String getInitial()

Specified by:

getInitial in interface org.apache.pig.Algebraic

getIntermed

public String getIntermed()

Specified by:

getIntermed in interface org.apache.pig.Algebraic

getFinal

public String getFinal()

Specified by:

getFinal in interface org.apache.pig.Algebraic

exec

public org.apache.pig.data.Tuple exec(org.apache.pig.data.Tuple inputTuple)
                               throws IOException

Specified by:

exec in class org.apache.pig.EvalFunc<org.apache.pig.data.Tuple>

Throws:

IOException

accumulate

public void accumulate(org.apache.pig.data.Tuple inputTuple)
                throws IOException

Specified by:

accumulate in interface org.apache.pig.Accumulator<org.apache.pig.data.Tuple>

Throws:

IOException

getValue

public org.apache.pig.data.Tuple getValue()

Specified by:

getValue in interface org.apache.pig.Accumulator<org.apache.pig.data.Tuple>

cleanup

public void cleanup()

Specified by:

cleanup in interface org.apache.pig.Accumulator<org.apache.pig.data.Tuple>