|
Change Parameter Type rightBound : int to rightBound : long in method public RowUnboundedPrecedingOverFrame(aggsHandleFunction GeneratedAggsHandleFunction, rightBound long) in class org.apache.flink.table.runtime.over.frame.RowUnboundedPrecedingOverFrame |
From |
To |
|
Change Parameter Type offset : long to offset : Long in method public OffsetOverFrame(aggsHandleFunction GeneratedAggsHandleFunction, offset Long, calcOffsetFunc CalcOffsetFunc) in class org.apache.flink.table.runtime.over.frame.OffsetOverFrame |
From |
To |
|
Change Parameter Type leftBound : int to leftBound : long in method public RowSlidingOverFrame(inputType RowType, valueType RowType, aggsHandleFunction GeneratedAggsHandleFunction, leftBound long, rightBound long) in class org.apache.flink.table.runtime.over.frame.RowSlidingOverFrame |
From |
To |
|
Change Parameter Type rightBound : int to rightBound : long in method public RowSlidingOverFrame(inputType RowType, valueType RowType, aggsHandleFunction GeneratedAggsHandleFunction, leftBound long, rightBound long) in class org.apache.flink.table.runtime.over.frame.RowSlidingOverFrame |
From |
To |
|
Change Parameter Type calcOffsetFunc : Function<BaseRow,Long> to calcOffsetFunc : CalcOffsetFunc in method public OffsetOverFrame(aggsHandleFunction GeneratedAggsHandleFunction, offset Long, calcOffsetFunc CalcOffsetFunc) in class org.apache.flink.table.runtime.over.frame.OffsetOverFrame |
From |
To |
|
Change Parameter Type leftBound : int to leftBound : long in method public RowUnboundedFollowingOverFrame(valueType RowType, aggsHandleFunction GeneratedAggsHandleFunction, leftBound long) in class org.apache.flink.table.runtime.over.frame.RowUnboundedFollowingOverFrame |
From |
To |
|
Change Parameter Type memorySize : int to memorySize : long in method public BufferDataOverWindowOperator(memorySize long, overWindowFrames OverWindowFrame[], genComparator GeneratedRecordComparator, isRowAllInFixedPart boolean) in class org.apache.flink.table.runtime.over.BufferDataOverWindowOperator |
From |
To |
|
Change Attribute Type memorySize : int to memorySize : long in class org.apache.flink.table.runtime.over.BufferDataOverWindowOperator |
From |
To |
|
Change Attribute Type rightBound : int to rightBound : long in class org.apache.flink.table.runtime.over.frame.RowUnboundedPrecedingOverFrame |
From |
To |
|
Change Attribute Type calcOffsetFunc : Function<BaseRow,Long> to calcOffsetFunc : CalcOffsetFunc in class org.apache.flink.table.runtime.over.frame.OffsetOverFrame |
From |
To |
|
Change Attribute Type rightBound : int to rightBound : long in class org.apache.flink.table.runtime.over.frame.RowSlidingOverFrame |
From |
To |
|
Change Attribute Type offset : long to offset : Long in class org.apache.flink.table.runtime.over.frame.OffsetOverFrame |
From |
To |
|
Change Attribute Type leftBound : int to leftBound : long in class org.apache.flink.table.runtime.over.frame.RowSlidingOverFrame |
From |
To |
|
Change Attribute Type inputRightIndex : int to inputRightIndex : long in class org.apache.flink.table.runtime.over.frame.RowUnboundedPrecedingOverFrame |
From |
To |
|
Change Attribute Type leftBound : int to leftBound : long in class org.apache.flink.table.runtime.over.frame.RowUnboundedFollowingOverFrame |
From |
To |