stream.scotty.slicing.slice

Class EagerSlice<InputType,ValueType>

java.lang.Object

slice.stream.scotty.slicing.AbstractSlice<InputType,ValueType>

slice.stream.scotty.slicing.EagerSlice<InputType,ValueType>

All Implemented Interfaces:

Slice<InputType,ValueType>

public class EagerSlice<InputType,ValueType>
extends AbstractSlice<InputType,ValueType>

Nested Class Summary

Nested classes/interfaces inherited from interface stream.scotty.slicing.slice.Slice

Slice.Fixed, Slice.Flexible, Slice.Type

Field Summary

Fields

Modifier and Type	Field and Description
private AggregationState<InputType>	state
private WindowManager	windowManager

Constructor Summary

Constructors

Constructor and Description
EagerSlice(StateFactory stateFactory, WindowManager windowManager, long startTs, long endTs, Slice.Type type)

Method Summary

Modifier and Type	Method and Description
void	addElement(InputType element, long ts) Add a element to the slice.
AggregationState	getAggState()

Methods inherited from class stream.scotty.slicing.slice.AbstractSlice

getTEnd, getTFirst, getTLast, getTStart, getType, merge, setTEnd, setTStart, setType, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

state

private final AggregationState<InputType> state

windowManager

private final WindowManager windowManager

Constructor Detail

EagerSlice

public EagerSlice(StateFactory stateFactory,
                  WindowManager windowManager,
                  long startTs,
                  long endTs,
                  Slice.Type type)

Method Detail

getAggState

public AggregationState getAggState()

Returns:

addElement

public void addElement(InputType element,
                       long ts)

Description copied from interface: Slice

Add a element to the slice.

Specified by:

addElement in interface Slice<InputType,ValueType>

Overrides:

addElement in class AbstractSlice<InputType,ValueType>

Parameters:

element - the element which is added

ts - timestamp of the element