org.apache.hadoop.hive.ql.udf.ptf

Class WindowingTableFunction.DoubleValueBoundaryScanner

java.lang.Object

org.apache.hadoop.hive.ql.udf.ptf.WindowingTableFunction.DoubleValueBoundaryScanner

Enclosing class:

WindowingTableFunction

public static class WindowingTableFunction.DoubleValueBoundaryScanner
extends Object

Constructor Summary

Constructors

Constructor and Description
WindowingTableFunction.DoubleValueBoundaryScanner(BoundaryDef bndDef, PTFInvocationSpec.Order order, PTFExpressionDef expressionDef)

Method Summary

Methods

Modifier and Type	Method and Description
protected int	computeEnd(int rowIdx, PTFPartition p)
protected int	computeEndCurrentRow(int rowIdx, PTFPartition p)
protected int	computeEndFollowing(int rowIdx, PTFPartition p)
protected int	computeEndPreceding(int rowIdx, PTFPartition p)
protected int	computeStart(int rowIdx, PTFPartition p)
protected int	computeStartCurrentRow(int rowIdx, PTFPartition p)
protected int	computeStartFollowing(int rowIdx, PTFPartition p)
protected int	computeStartPreceding(int rowIdx, PTFPartition p)
Object	computeValue(Object row)
static org.apache.hadoop.hive.ql.udf.ptf.WindowingTableFunction.ValueBoundaryScanner	getScanner(ValueBoundaryDef vbDef, PTFInvocationSpec.Order order)
boolean	isEqual(Object v1, Object v2)
boolean	isGreater(Object v1, Object v2, int amt)
void	reset(BoundaryDef bndDef)

Methods inherited from class java.lang.Object

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

Constructor Detail

WindowingTableFunction.DoubleValueBoundaryScanner

public WindowingTableFunction.DoubleValueBoundaryScanner(BoundaryDef bndDef,
                                                 PTFInvocationSpec.Order order,
                                                 PTFExpressionDef expressionDef)

Method Detail

isGreater

public boolean isGreater(Object v1,
                Object v2,
                int amt)

isEqual

public boolean isEqual(Object v1,
              Object v2)

reset

public void reset(BoundaryDef bndDef)

computeStart

protected int computeStart(int rowIdx,
               PTFPartition p)
                    throws HiveException

Throws:

HiveException

computeStartPreceding

protected int computeStartPreceding(int rowIdx,
                        PTFPartition p)
                             throws HiveException

Throws:

HiveException

computeStartCurrentRow

protected int computeStartCurrentRow(int rowIdx,
                         PTFPartition p)
                              throws HiveException

Throws:

HiveException

computeStartFollowing

protected int computeStartFollowing(int rowIdx,
                        PTFPartition p)
                             throws HiveException

Throws:

HiveException

computeEnd

protected int computeEnd(int rowIdx,
             PTFPartition p)
                  throws HiveException

Throws:

HiveException

computeEndPreceding

protected int computeEndPreceding(int rowIdx,
                      PTFPartition p)
                           throws HiveException

Throws:

HiveException

computeEndCurrentRow

protected int computeEndCurrentRow(int rowIdx,
                       PTFPartition p)
                            throws HiveException

Throws:

HiveException

computeEndFollowing

protected int computeEndFollowing(int rowIdx,
                      PTFPartition p)
                           throws HiveException

Throws:

HiveException

computeValue

public Object computeValue(Object row)
                    throws HiveException

Throws:

HiveException

getScanner

public static org.apache.hadoop.hive.ql.udf.ptf.WindowingTableFunction.ValueBoundaryScanner getScanner(ValueBoundaryDef vbDef,
                                                                                       PTFInvocationSpec.Order order)
                                                                                                throws HiveException

Throws:

HiveException