org.apache.pig.impl.builtin

Class FindQuantiles

java.lang.Object

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

org.apache.pig.impl.builtin.FindQuantiles

Direct Known Subclasses:

FindQuantilesTez

public class FindQuantiles
extends EvalFunc<java.util.Map<java.lang.String,java.lang.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 java.lang.Integer	numQuantiles
static java.lang.String	QUANTILES_LIST
protected DataBag	samples
static java.lang.String	WEIGHTED_PARTS

Fields inherited from class org.apache.pig.EvalFunc

log, pigLogger, reporter, returnType

Constructor Summary

Constructors

Constructor and Description
FindQuantiles()
FindQuantiles(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

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

Field Detail

QUANTILES_LIST

public static final java.lang.String QUANTILES_LIST

See Also:

Constant Field Values

WEIGHTED_PARTS

public static final java.lang.String WEIGHTED_PARTS

See Also:

Constant Field Values

numQuantiles

protected java.lang.Integer numQuantiles

samples

protected DataBag samples

Constructor Detail

FindQuantiles

public FindQuantiles()

FindQuantiles

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

Method Detail

exec

public java.util.Map<java.lang.String,java.lang.Object> exec(Tuple in)
                                                      throws java.io.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<java.util.Map<java.lang.String,java.lang.Object>>

Parameters:

in - the Tuple to be processed.

Returns:

result, of type T.

Throws:

java.io.IOException