stream.scotty.slicing

Class SliceManager<InputType>

java.lang.Object

stream.scotty.slicing.SliceManager<InputType>

public class SliceManager<InputType>
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
private AggregationStore<InputType>	aggregationStore
private SliceFactory<InputType,?>	sliceFactory
private WindowManager	windowManager

Constructor Summary

Constructors

Constructor and Description
SliceManager(SliceFactory sliceFactory, AggregationStore<InputType> aggregationStore, WindowManager windowManager)

Method Summary

Modifier and Type	Method and Description
void	appendSlice(long startTs, Slice.Type type) Append a new slice.
private void	checkSliceEdges(java.util.Set<WindowModifications> windowModifications)
void	processElement(InputType element, long ts) Process a tuple and insert it in the correct slice.
void	splitSlice(int sliceIndex, long timestamp)

Methods inherited from class java.lang.Object

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

Field Detail

sliceFactory

private final SliceFactory<InputType,?> sliceFactory

aggregationStore

private final AggregationStore<InputType> aggregationStore

windowManager

private final WindowManager windowManager

Constructor Detail

SliceManager

public SliceManager(SliceFactory sliceFactory,
                    AggregationStore<InputType> aggregationStore,
                    WindowManager windowManager)

Method Detail

appendSlice

public void appendSlice(long startTs,
                        Slice.Type type)

Append a new slice. This method is called by the StreamSlicer

Parameters:

startTs - the start timestamp of the new slice or end timestamp of the previous slice

type - the end measure of the previous slice

processElement

public void processElement(InputType element,
                           long ts)

Process a tuple and insert it in the correct slice. Depending of the WindowMeasure slices have to be adopted under some conditions.

Parameters:

element - the element which is inserted

ts - the element timestamp

checkSliceEdges

private void checkSliceEdges(java.util.Set<WindowModifications> windowModifications)

splitSlice

public void splitSlice(int sliceIndex,
                       long timestamp)