Class UnboundedPrecedingOverFrame
- java.lang.Object
-
- org.apache.flink.table.runtime.operators.over.frame.UnboundedPrecedingOverFrame
-
- All Implemented Interfaces:
Serializable,OverWindowFrame
- Direct Known Subclasses:
RangeUnboundedPrecedingOverFrame,RowUnboundedPrecedingOverFrame
public abstract class UnboundedPrecedingOverFrame extends Object implements OverWindowFrame
The UnboundedPreceding window frame. SeeRowUnboundedPrecedingOverFrameandRangeUnboundedPrecedingOverFrame.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description UnboundedPrecedingOverFrame(GeneratedAggsHandleFunction aggsHandleFunction)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidopen(ExecutionContext ctx)Open to init withExecutionContext.voidprepare(ResettableExternalBuffer rows)Prepare for next partition.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.flink.table.runtime.operators.over.frame.OverWindowFrame
process
-
-
-
-
Constructor Detail
-
UnboundedPrecedingOverFrame
public UnboundedPrecedingOverFrame(GeneratedAggsHandleFunction aggsHandleFunction)
-
-
Method Detail
-
open
public void open(ExecutionContext ctx) throws Exception
Description copied from interface:OverWindowFrameOpen to init withExecutionContext.- Specified by:
openin interfaceOverWindowFrame- Throws:
Exception
-
prepare
public void prepare(ResettableExternalBuffer rows) throws Exception
Description copied from interface:OverWindowFramePrepare for next partition.- Specified by:
preparein interfaceOverWindowFrame- Throws:
Exception
-
-