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

Class PartitionSkewedKeysTez

java.lang.Object

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

org.apache.pig.impl.builtin.PartitionSkewedKeys

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

public class PartitionSkewedKeysTez
extends PartitionSkewedKeys

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.PartitionSkewedKeys

DEFAULT_PERCENT_MEMUSAGE, PARTITION_LIST, TOTAL_REDUCERS, totalReducers_

Fields inherited from class org.apache.pig.EvalFunc

pigLogger, reporter, returnType

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
Map<String,Object>	exec(Tuple in) first field in the input tuple is the number of reducers second field is the *sorted* bag of samples this should be called only once

Methods inherited from class org.apache.pig.impl.builtin.PartitionSkewedKeys

getMemorySize

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

PartitionSkewedKeysTez

public PartitionSkewedKeysTez()

PartitionSkewedKeysTez

public PartitionSkewedKeysTez(String[] args)

Method Detail

exec

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

Description copied from class: PartitionSkewedKeys

first field in the input tuple is the number of reducers second field is the *sorted* bag of samples this should be called only once

Overrides:

exec in class PartitionSkewedKeys

Parameters:

in - the Tuple to be processed.

Returns:

result, of type T.

Throws:

IOException