stream.scotty.slicing

Class AggregationState<InputType>

java.lang.Object

stream.scotty.slicing.AggregationState<InputType>

All Implemented Interfaces:

java.io.Serializable

public class AggregationState<InputType>
extends java.lang.Object
implements java.io.Serializable

See Also:

Serialized Form

Field Summary

Fields

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 Summary

Constructors

Constructor and Description
AggregationState(StateFactory stateFactory, java.util.List<AggregateFunction> windowFunctions)

Method Summary

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()

Methods inherited from class java.lang.Object

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

Field Detail

windowFunctions

private final java.util.List<AggregateFunction> windowFunctions

valueStates

private final java.util.List<ValueState<java.lang.Object>> valueStates

empty

private boolean empty

Constructor Detail

AggregationState

public AggregationState(StateFactory stateFactory,
                        java.util.List<AggregateFunction> windowFunctions)

Method Detail

addElement

public void addElement(InputType state)

addElementToValueState

public void addElementToValueState(InputType element,
                                   ValueState<java.lang.Object> valueState,
                                   AggregateFunction windowFunction)

merge

public void merge(AggregationState<InputType> otherAggState)

isMergeable

private boolean isMergeable(AggregationState otherAggState)

getValues

public java.util.List<java.lang.Object> getValues()

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object