public static class WindowingTableFunction.StringValueBoundaryScanner
extends java.lang.Object
Constructor and Description |
---|
StringValueBoundaryScanner(PTFDesc.BoundaryDef bndDef,
PTFInvocationSpec.Order order,
PTFDesc.PTFExpressionDef expressionDef) |
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) |
java.lang.Object |
computeValue(java.lang.Object row) |
static org.apache.hadoop.hive.ql.udf.ptf.WindowingTableFunction.ValueBoundaryScanner |
getScanner(PTFDesc.ValueBoundaryDef vbDef,
PTFInvocationSpec.Order order) |
boolean |
isEqual(java.lang.Object v1,
java.lang.Object v2) |
boolean |
isGreater(java.lang.Object v1,
java.lang.Object v2,
int amt) |
void |
reset(PTFDesc.BoundaryDef bndDef) |
public StringValueBoundaryScanner(PTFDesc.BoundaryDef bndDef, PTFInvocationSpec.Order order, PTFDesc.PTFExpressionDef expressionDef)
public boolean isGreater(java.lang.Object v1, java.lang.Object v2, int amt)
public boolean isEqual(java.lang.Object v1, java.lang.Object v2)
public void reset(PTFDesc.BoundaryDef bndDef)
protected int computeStart(int rowIdx, PTFPartition p) throws HiveException
HiveException
protected int computeStartPreceding(int rowIdx, PTFPartition p) throws HiveException
HiveException
protected int computeStartCurrentRow(int rowIdx, PTFPartition p) throws HiveException
HiveException
protected int computeStartFollowing(int rowIdx, PTFPartition p) throws HiveException
HiveException
protected int computeEnd(int rowIdx, PTFPartition p) throws HiveException
HiveException
protected int computeEndPreceding(int rowIdx, PTFPartition p) throws HiveException
HiveException
protected int computeEndCurrentRow(int rowIdx, PTFPartition p) throws HiveException
HiveException
protected int computeEndFollowing(int rowIdx, PTFPartition p) throws HiveException
HiveException
public java.lang.Object computeValue(java.lang.Object row) throws HiveException
HiveException
public static org.apache.hadoop.hive.ql.udf.ptf.WindowingTableFunction.ValueBoundaryScanner getScanner(PTFDesc.ValueBoundaryDef vbDef, PTFInvocationSpec.Order order) throws HiveException
HiveException
Copyright © 2012 The Apache Software Foundation