public class RangeUnboundedFollowingOverFrame extends UnboundedFollowingOverFrame
e.g.: ... RANGE BETWEEN 1 PRECEDING AND UNBOUNDED FOLLOWING.
Constructor and Description |
---|
RangeUnboundedFollowingOverFrame(RowType valueType,
GeneratedAggsHandleFunction aggsHandleFunction,
GeneratedRecordComparator boundComparator) |
Modifier and Type | Method and Description |
---|---|
void |
open(ExecutionContext ctx)
Open to init with
ExecutionContext . |
BaseRow |
process(int index,
BaseRow current)
return the ACC of the window frame.
|
prepare
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getNextOrNull
public RangeUnboundedFollowingOverFrame(RowType valueType, GeneratedAggsHandleFunction aggsHandleFunction, GeneratedRecordComparator boundComparator)
public void open(ExecutionContext ctx) throws Exception
OverWindowFrame
ExecutionContext
.open
in interface OverWindowFrame
open
in class UnboundedFollowingOverFrame
Exception
public BaseRow process(int index, BaseRow current) throws Exception
OverWindowFrame
Exception
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.