datafu.org.apache.pig.piggybank.evaluation

Class ExtremalTupleByNthField

java.lang.Object

org.apache.pig.EvalFunc<org.apache.pig.data.Tuple>

datafu.org.apache.pig.piggybank.evaluation.ExtremalTupleByNthField

All Implemented Interfaces:

org.apache.pig.Accumulator<org.apache.pig.data.Tuple>, org.apache.pig.Algebraic

public class ExtremalTupleByNthField
extends org.apache.pig.EvalFunc<org.apache.pig.data.Tuple>
implements org.apache.pig.Algebraic, org.apache.pig.Accumulator<org.apache.pig.data.Tuple>

This class is a copy of org.apache.pig.piggybank.evaluation.ExtremalTupleByNthField https://github.com/apache/pig/blob/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/evaluation/ExtremalTupleByNthField.java

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ExtremalTupleByNthField.HelperClass Utility classes and methods

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

org.apache.pig.EvalFunc.SchemaType

Field Summary

Fields inherited from class org.apache.pig.EvalFunc

log, pigLogger, reporter, returnType

Constructor Summary

Constructors

Constructor and Description
ExtremalTupleByNthField()
ExtremalTupleByNthField(java.lang.String fieldIndexString)
ExtremalTupleByNthField(java.lang.String fieldIndexString, java.lang.String order)

Method Summary

Modifier and Type	Method and Description
void	accumulate(org.apache.pig.data.Tuple b)
void	cleanup()
org.apache.pig.data.Tuple	exec(org.apache.pig.data.Tuple input) The EvalFunc interface
protected static org.apache.pig.data.Tuple	extreme(int pind, int psign, org.apache.pig.data.Tuple input, org.apache.pig.backend.hadoop.executionengine.physicalLayer.PigProgressable reporter)
java.lang.String	getFinal()
java.lang.String	getInitial() Algebraic interface
java.lang.String	getIntermed()
java.lang.reflect.Type	getReturnType()
org.apache.pig.data.Tuple	getValue()
org.apache.pig.impl.logicalLayer.schema.Schema	outputSchema(org.apache.pig.impl.logicalLayer.schema.Schema input)
protected static int	parseFieldIndex(java.lang.String inputFieldIndex)
protected static int	parseOrdering(java.lang.String order)

Methods inherited from class org.apache.pig.EvalFunc

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

ExtremalTupleByNthField

public ExtremalTupleByNthField()
                        throws org.apache.pig.backend.executionengine.ExecException

Throws:

org.apache.pig.backend.executionengine.ExecException

ExtremalTupleByNthField

public ExtremalTupleByNthField(java.lang.String fieldIndexString)
                        throws org.apache.pig.backend.executionengine.ExecException

Throws:

org.apache.pig.backend.executionengine.ExecException

ExtremalTupleByNthField

public ExtremalTupleByNthField(java.lang.String fieldIndexString,
                               java.lang.String order)
                        throws org.apache.pig.backend.executionengine.ExecException

Throws:

org.apache.pig.backend.executionengine.ExecException

Method Detail

exec

public org.apache.pig.data.Tuple exec(org.apache.pig.data.Tuple input)
                               throws java.io.IOException

The EvalFunc interface

Specified by:

exec in class org.apache.pig.EvalFunc<org.apache.pig.data.Tuple>

Throws:

java.io.IOException

getReturnType

public java.lang.reflect.Type getReturnType()

Overrides:

getReturnType in class org.apache.pig.EvalFunc<org.apache.pig.data.Tuple>

outputSchema

public org.apache.pig.impl.logicalLayer.schema.Schema outputSchema(org.apache.pig.impl.logicalLayer.schema.Schema input)

Overrides:

outputSchema in class org.apache.pig.EvalFunc<org.apache.pig.data.Tuple>

getInitial

public java.lang.String getInitial()

Algebraic interface

Specified by:

getInitial in interface org.apache.pig.Algebraic

getIntermed

public java.lang.String getIntermed()

Specified by:

getIntermed in interface org.apache.pig.Algebraic

getFinal

public java.lang.String getFinal()

Specified by:

getFinal in interface org.apache.pig.Algebraic

accumulate

public void accumulate(org.apache.pig.data.Tuple b)
                throws java.io.IOException

Specified by:

accumulate in interface org.apache.pig.Accumulator<org.apache.pig.data.Tuple>

Throws:

java.io.IOException

cleanup

public void cleanup()

Specified by:

cleanup in interface org.apache.pig.Accumulator<org.apache.pig.data.Tuple>

getValue

public org.apache.pig.data.Tuple getValue()

Specified by:

getValue in interface org.apache.pig.Accumulator<org.apache.pig.data.Tuple>

extreme

protected static final org.apache.pig.data.Tuple extreme(int pind,
                                                         int psign,
                                                         org.apache.pig.data.Tuple input,
                                                         org.apache.pig.backend.hadoop.executionengine.physicalLayer.PigProgressable reporter)
                                                  throws org.apache.pig.backend.executionengine.ExecException

Throws:

org.apache.pig.backend.executionengine.ExecException

parseFieldIndex

protected static int parseFieldIndex(java.lang.String inputFieldIndex)
                              throws org.apache.pig.backend.executionengine.ExecException

Throws:

org.apache.pig.backend.executionengine.ExecException

parseOrdering

protected static int parseOrdering(java.lang.String order)