public class UnionArrayOfDoublesSketch
extends org.apache.pig.EvalFunc<org.apache.pig.data.Tuple>
implements org.apache.pig.Algebraic
Modifier and Type | Class and Description |
---|---|
static class |
UnionArrayOfDoublesSketch.Initial |
static class |
UnionArrayOfDoublesSketch.IntermediateFinal |
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.
|
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() |
allowCompileTimeCalculation, finish, getArgToFuncMapping, getCacheFiles, getInputSchema, getLoadCaster, getLogger, getPigLogger, getReporter, getReturnType, getSchemaName, getSchemaType, getShipFiles, isAsynchronous, needEndOfAllInputProcessing, outputSchema, progress, setEndOfAllInput, setInputSchema, setPigLogger, setReporter, setUDFContextSignature, warn
public UnionArrayOfDoublesSketch()
public UnionArrayOfDoublesSketch(String numValues)
numValues
- String representation of number of values per keypublic String getInitial()
getInitial
in interface org.apache.pig.Algebraic
public String getIntermed()
getIntermed
in interface org.apache.pig.Algebraic
public String getFinal()
getFinal
in interface org.apache.pig.Algebraic
public org.apache.pig.data.Tuple exec(org.apache.pig.data.Tuple inputTuple) throws IOException
exec
in class org.apache.pig.EvalFunc<org.apache.pig.data.Tuple>
IOException
public void accumulate(org.apache.pig.data.Tuple inputTuple) throws IOException
accumulate
in interface org.apache.pig.Accumulator<org.apache.pig.data.Tuple>
IOException
public org.apache.pig.data.Tuple getValue()
getValue
in interface org.apache.pig.Accumulator<org.apache.pig.data.Tuple>
public void cleanup()
cleanup
in interface org.apache.pig.Accumulator<org.apache.pig.data.Tuple>
Copyright © 2015–2019 The Apache Software Foundation. All rights reserved.