public class StreamSlicer
extends java.lang.Object
| Modifier and Type | Class and Description |
|---|---|
private class |
StreamSlicer.Edge |
| 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 and Description |
|---|
StreamSlicer(SliceManager<?> sliceManager,
WindowManager windowManager) |
| 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
|
private final SliceManager<?> sliceManager
private final WindowManager windowManager
private long maxEventTime
private long min_next_edge
private long count_between_edges
public StreamSlicer(SliceManager<?> sliceManager, WindowManager windowManager)
public void determineSlices(long te)
te - event timestamp for which slices have to be createdprivate long calculateNextFixedEdge(long te)
private int calculateNextFlexEdge(long te)
private boolean isInOrder(long te)
te - event timestamp