org.apache.flink.table.runtime.operators.over.frame

Class RowUnboundedFollowingOverFrame

java.lang.Object

org.apache.flink.table.runtime.operators.over.frame.UnboundedFollowingOverFrame

org.apache.flink.table.runtime.operators.over.frame.RowUnboundedFollowingOverFrame

All Implemented Interfaces:

Serializable, OverWindowFrame

public class RowUnboundedFollowingOverFrame
extends UnboundedFollowingOverFrame

The row unboundedFollowing window frame calculates frames with the following SQL form: ... ROW BETWEEN [window frame preceding] AND UNBOUNDED FOLLOWING [window frame preceding] ::= [unsigned_value_specification] PRECEDING | CURRENT ROW

e.g.: ... ROW BETWEEN 1 PRECEDING AND UNBOUNDED FOLLOWING.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
RowUnboundedFollowingOverFrame(RowType valueType, GeneratedAggsHandleFunction aggsHandleFunction, long leftBound)

Method Summary

Modifier and Type	Method and Description
RowData	process(int index, RowData current) return the ACC of the window frame.

Methods inherited from class org.apache.flink.table.runtime.operators.over.frame.UnboundedFollowingOverFrame

open, prepare

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

getNextOrNull

Constructor Detail

RowUnboundedFollowingOverFrame

public RowUnboundedFollowingOverFrame(RowType valueType,
                                      GeneratedAggsHandleFunction aggsHandleFunction,
                                      long leftBound)

Method Detail

process

public RowData process(int index,
                       RowData current)
                throws Exception

Description copied from interface: OverWindowFrame

return the ACC of the window frame.

Throws:

Exception