public abstract class UnboundedFollowingOverFrame extends Object implements OverWindowFrame
RowUnboundedFollowingOverFrame
and RangeUnboundedFollowingOverFrame
.Constructor and Description |
---|
UnboundedFollowingOverFrame(RowType valueType,
GeneratedAggsHandleFunction aggsHandleFunction) |
Modifier and Type | Method and Description |
---|---|
void |
open(ExecutionContext ctx)
Open to init with
ExecutionContext . |
void |
prepare(ResettableExternalBuffer rows)
Prepare for next partition.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getNextOrNull, process
public UnboundedFollowingOverFrame(RowType valueType, GeneratedAggsHandleFunction aggsHandleFunction)
public void open(ExecutionContext ctx) throws Exception
OverWindowFrame
ExecutionContext
.open
in interface OverWindowFrame
Exception
public void prepare(ResettableExternalBuffer rows) throws Exception
OverWindowFrame
prepare
in interface OverWindowFrame
Exception
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.