public class AggregationState<InputType>
extends java.lang.Object
implements java.io.Serializable
| Modifier and Type | Field and Description |
|---|---|
private boolean |
empty |
private java.util.List<ValueState<java.lang.Object>> |
valueStates |
private java.util.List<AggregateFunction> |
windowFunctions |
| Constructor and Description |
|---|
AggregationState(StateFactory stateFactory,
java.util.List<AggregateFunction> windowFunctions) |
| Modifier and Type | Method and Description |
|---|---|
void |
addElement(InputType state) |
void |
addElementToValueState(InputType element,
ValueState<java.lang.Object> valueState,
AggregateFunction windowFunction) |
boolean |
equals(java.lang.Object o) |
java.util.List<java.lang.Object> |
getValues() |
int |
hashCode() |
private boolean |
isMergeable(AggregationState otherAggState) |
void |
merge(AggregationState<InputType> otherAggState) |
java.lang.String |
toString() |
private final java.util.List<AggregateFunction> windowFunctions
private final java.util.List<ValueState<java.lang.Object>> valueStates
private boolean empty
public AggregationState(StateFactory stateFactory, java.util.List<AggregateFunction> windowFunctions)
public void addElement(InputType state)
public void addElementToValueState(InputType element, ValueState<java.lang.Object> valueState, AggregateFunction windowFunction)
public void merge(AggregationState<InputType> otherAggState)
private boolean isMergeable(AggregationState otherAggState)
public java.util.List<java.lang.Object> getValues()
public boolean equals(java.lang.Object o)
equals in class java.lang.Objectpublic int hashCode()
hashCode in class java.lang.Objectpublic java.lang.String toString()
toString in class java.lang.Object