org.apache.pig.impl.builtin

Class FindQuantiles

java.lang.Object

org.apache.pig.EvalFunc<Map<String,Object>>

org.apache.pig.impl.builtin.FindQuantiles

Direct Known Subclasses:

FindQuantilesTez

public class FindQuantiles
extends EvalFunc<Map<String,Object>>

Nested Class Summary

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

EvalFunc.SchemaType

Field Summary

Fields

Modifier and Type	Field and Description
protected Integer	numQuantiles
static String	QUANTILES_LIST
protected DataBag	samples
static String	WEIGHTED_PARTS

Fields inherited from class org.apache.pig.EvalFunc

log, pigLogger, reporter, returnType

Constructor Summary

Constructors

Constructor and Description
FindQuantiles()
FindQuantiles(String[] args)

Method Summary

Methods

Modifier and Type	Method and Description
Map<String,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

Methods inherited from class org.apache.pig.EvalFunc

allowCompileTimeCalculation, finish, getArgToFuncMapping, getCacheFiles, getInputSchema, 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

Field Detail

QUANTILES_LIST

public static final String QUANTILES_LIST

See Also:

Constant Field Values

WEIGHTED_PARTS

public static final String WEIGHTED_PARTS

See Also:

Constant Field Values

numQuantiles

protected Integer numQuantiles

samples

protected DataBag samples

Constructor Detail

FindQuantiles

public FindQuantiles()

FindQuantiles

public FindQuantiles(String[] args)

Method Detail

exec

public Map<String,Object> exec(Tuple in)
                        throws IOException

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

Specified by:

exec in class EvalFunc<Map<String,Object>>

Parameters:

in - the Tuple to be processed.

Returns:

result, of type T.

Throws:

IOException