org.apache.flink.table.runtime.functions.aggregate

Class FirstValueWithRetractAggFunction.FirstValueWithRetractAccumulator<T>

java.lang.Object

org.apache.flink.table.runtime.functions.aggregate.FirstValueWithRetractAggFunction.FirstValueWithRetractAccumulator<T>

Enclosing class:

FirstValueWithRetractAggFunction<T>

public static class FirstValueWithRetractAggFunction.FirstValueWithRetractAccumulator<T>
extends Object

Accumulator for FIRST_VALUE.

Field Summary

Fields

Modifier and Type	Field and Description
Long	firstOrder
T	firstValue
MapView<Long,List<T>>	orderToValueMap
MapView<T,List<Long>>	valueToOrderMap

Constructor Summary

Constructors

Constructor and Description
FirstValueWithRetractAccumulator()

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
int	hashCode()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Field Detail

firstValue

public T firstValue

firstOrder

public Long firstOrder

valueToOrderMap

public MapView<T,List<Long>> valueToOrderMap

orderToValueMap

public MapView<Long,List<T>> orderToValueMap

Constructor Detail

FirstValueWithRetractAccumulator

public FirstValueWithRetractAccumulator()

Method Detail

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object