public class RangeSlidingOverFrame extends SlidingOverFrame
e.g.: ... RANGE BETWEEN 1 PRECEDING AND 1 FOLLOWING.
Constructor and Description |
---|
RangeSlidingOverFrame(RowType inputType,
RowType valueType,
GeneratedAggsHandleFunction aggsHandleFunction,
GeneratedRecordComparator lboundComparator,
GeneratedRecordComparator rboundComparator) |
Modifier and Type | Method and Description |
---|---|
void |
open(ExecutionContext ctx)
Open to init with
ExecutionContext . |
RowData |
process(int index,
RowData current)
return the ACC of the window frame.
|
prepare
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getNextOrNull
public RangeSlidingOverFrame(RowType inputType, RowType valueType, GeneratedAggsHandleFunction aggsHandleFunction, GeneratedRecordComparator lboundComparator, GeneratedRecordComparator rboundComparator)
lboundComparator
- comparator used to identify the lower bound of an output row.rboundComparator
- comparator used to identify the upper bound of an output row.public void open(ExecutionContext ctx) throws Exception
OverWindowFrame
ExecutionContext
.open
in interface OverWindowFrame
open
in class SlidingOverFrame
Exception
public RowData process(int index, RowData current) throws Exception
OverWindowFrame
Exception
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.