org.apache.pig.backend.hadoop.executionengine.tez.plan.udf

Class FindQuantilesTez

java.lang.Object

org.apache.pig.EvalFunc<java.util.Map<java.lang.String,java.lang.Object>>

org.apache.pig.impl.builtin.FindQuantiles

org.apache.pig.backend.hadoop.executionengine.tez.plan.udf.FindQuantilesTez

public class FindQuantilesTez
extends FindQuantiles

Nested Class Summary

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

EvalFunc.SchemaType

Field Summary

Fields inherited from class org.apache.pig.impl.builtin.FindQuantiles

numQuantiles, QUANTILES_LIST, samples, WEIGHTED_PARTS

Fields inherited from class org.apache.pig.EvalFunc

log, pigLogger, reporter, returnType

Constructor Summary

Constructors

Constructor and Description
FindQuantilesTez()
FindQuantilesTez(java.lang.String[] args)

Method Summary

Methods

Modifier and Type	Method and Description
java.util.Map<java.lang.String,java.lang.Object>	exec(Tuple in) first field in the input tuple is the number of quantiles to generate second field is the *sorted* bag of samples
protected long	getMemorySize(Tuple t)

Methods inherited from class org.apache.pig.EvalFunc

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

FindQuantilesTez

public FindQuantilesTez()

FindQuantilesTez

public FindQuantilesTez(java.lang.String[] args)

Method Detail

exec

public java.util.Map<java.lang.String,java.lang.Object> exec(Tuple in)
                                                      throws java.io.IOException

Description copied from class: FindQuantiles

first field in the input tuple is the number of quantiles to generate second field is the *sorted* bag of samples

Overrides:

exec in class FindQuantiles

Parameters:

in - the Tuple to be processed.

Returns:

result, of type T.

Throws:

java.io.IOException

getMemorySize

protected long getMemorySize(Tuple t)