stream.scotty.slicing

Class StreamSlicer

java.lang.Object

stream.scotty.slicing.StreamSlicer

public class StreamSlicer
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	StreamSlicer.Edge

Field Summary

Fields

Modifier and Type	Field and Description
private long	count_between_edges
private long	maxEventTime
private long	min_next_edge
private SliceManager<?>	sliceManager
private WindowManager	windowManager

Constructor Summary

Constructors

Constructor and Description
StreamSlicer(SliceManager<?> sliceManager, WindowManager windowManager)

Method Summary

Modifier and Type	Method and Description
private long	calculateNextFixedEdge(long te)
private int	calculateNextFlexEdge(long te)
void	determineSlices(long te) Processes every tuple in the data stream and checks if new slices have to be created
private boolean	isInOrder(long te) Checks if timestamp is >= @maxEventTime

Methods inherited from class java.lang.Object

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

Field Detail

sliceManager

private final SliceManager<?> sliceManager

windowManager

private final WindowManager windowManager

maxEventTime

private long maxEventTime

min_next_edge

private long min_next_edge

count_between_edges

private long count_between_edges

Constructor Detail

StreamSlicer

public StreamSlicer(SliceManager<?> sliceManager,
                    WindowManager windowManager)

Method Detail

determineSlices

public void determineSlices(long te)

Processes every tuple in the data stream and checks if new slices have to be created

Parameters:

te - event timestamp for which slices have to be created

calculateNextFixedEdge

private long calculateNextFixedEdge(long te)

calculateNextFlexEdge

private int calculateNextFlexEdge(long te)

isInOrder

private boolean isInOrder(long te)

Checks if timestamp is >= @maxEventTime

Parameters:

te - event timestamp

Returns:

boolean