org.apache.hadoop.hive.ql.udf.generic

Class GenericUDFLeadLag

java.lang.Object

org.apache.hadoop.hive.ql.udf.generic.GenericUDF

org.apache.hadoop.hive.ql.udf.generic.GenericUDFLeadLag

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

GenericUDFLag, GenericUDFLead

public abstract class GenericUDFLeadLag
extends GenericUDF

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hive.ql.udf.generic.GenericUDF

GenericUDF.DeferredJavaObject, GenericUDF.DeferredObject

Constructor Summary

Constructors

Constructor and Description
GenericUDFLeadLag()

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract String	_getFnName()
Object	evaluate(GenericUDF.DeferredObject[] arguments) Evaluate the GenericUDF with the arguments.
int	getAmt()
ObjectInspector	getDefaultArgOI()
ObjectInspectorConverters.Converter	getDefaultValueConverter()
String	getDisplayString(String[] children) Get the String to be displayed in explain.
ExprNodeEvaluator	getExprEvaluator()
ObjectInspector	getFirstArgOI()
protected abstract int	getIndex(int amt)
PTFPartition.PTFPartitionIterator<Object>	getpItr()
protected abstract Object	getRow(int amt)
ObjectInspector	initialize(ObjectInspector[] arguments) Initialize this GenericUDF.
void	setAmt(int amt)
void	setDefaultArgOI(ObjectInspector defaultArgOI)
void	setDefaultValueConverter(ObjectInspectorConverters.Converter defaultValueConverter)
void	setExprEvaluator(ExprNodeEvaluator exprEvaluator)
void	setFirstArgOI(ObjectInspector firstArgOI)
void	setpItr(PTFPartition.PTFPartitionIterator<Object> pItr)

Methods inherited from class org.apache.hadoop.hive.ql.udf.generic.GenericUDF

checkArgGroups, checkArgPrimitive, checkArgsSize, close, configure, copyToNewInstance, flip, getArgOrder, getConstantIntValue, getConstantLongValue, getConstantStringValue, getDateValue, getDoubleValue, getFuncName, getIntValue, getLongValue, getRequiredFiles, getRequiredJars, getStandardDisplayString, getStandardDisplayString, getStringValue, getTimestampValue, getUdfName, initializeAndFoldConstants, negative, obtainDateConverter, obtainDoubleConverter, obtainIntConverter, obtainLongConverter, obtainStringConverter, obtainTimestampConverter

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GenericUDFLeadLag

public GenericUDFLeadLag()

Method Detail

evaluate

public Object evaluate(GenericUDF.DeferredObject[] arguments)
                throws HiveException

Description copied from class: GenericUDF

Evaluate the GenericUDF with the arguments.

Specified by:

evaluate in class GenericUDF

Parameters:

arguments - The arguments as DeferedObject, use DeferedObject.get() to get the actual argument Object. The Objects can be inspected by the ObjectInspectors passed in the initialize call.

Returns:

The

Throws:

HiveException

initialize

public ObjectInspector initialize(ObjectInspector[] arguments)
                           throws UDFArgumentException

Description copied from class: GenericUDF

Initialize this GenericUDF. This will be called once and only once per GenericUDF instance.

Specified by:

initialize in class GenericUDF

Parameters:

arguments - The ObjectInspector for the arguments

Returns:

The ObjectInspector for the return value

Throws:

UDFArgumentException - Thrown when arguments have wrong types, wrong length, etc.

getExprEvaluator

public ExprNodeEvaluator getExprEvaluator()

setExprEvaluator

public void setExprEvaluator(ExprNodeEvaluator exprEvaluator)

getpItr

public PTFPartition.PTFPartitionIterator<Object> getpItr()

setpItr

public void setpItr(PTFPartition.PTFPartitionIterator<Object> pItr)

getFirstArgOI

public ObjectInspector getFirstArgOI()

setFirstArgOI

public void setFirstArgOI(ObjectInspector firstArgOI)

getDefaultArgOI

public ObjectInspector getDefaultArgOI()

setDefaultArgOI

public void setDefaultArgOI(ObjectInspector defaultArgOI)

getDefaultValueConverter

public ObjectInspectorConverters.Converter getDefaultValueConverter()

setDefaultValueConverter

public void setDefaultValueConverter(ObjectInspectorConverters.Converter defaultValueConverter)

getAmt

public int getAmt()

setAmt

public void setAmt(int amt)

getDisplayString

public String getDisplayString(String[] children)

Description copied from class: GenericUDF

Get the String to be displayed in explain.

Specified by:

getDisplayString in class GenericUDF

_getFnName

protected abstract String _getFnName()

getRow

protected abstract Object getRow(int amt)
                          throws HiveException

Throws:

HiveException

getIndex

protected abstract int getIndex(int amt)