public class SessionWindowOperatorTest
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
private SlicingWindowOperator<java.lang.Integer> |
slicingWindowOperator |
private MemoryStateFactory |
stateFactory |
| Constructor and Description |
|---|
SessionWindowOperatorTest() |
| Modifier and Type | Method and Description |
|---|---|
void |
inOrderTest() |
void |
inOrderTest2() |
void |
outOfOrderCombinedSessionMultiSession() |
void |
outOfOrderCombinedSessionTumblingMegeSession() |
void |
outOfOrderTestLeftInsert() |
void |
outOfOrderTestMergeSlice() |
void |
outOfOrderTestRightInsert() |
void |
outOfOrderTestSimpleInsert() |
void |
outOfOrderTestSplitSlice() |
void |
setup() |
private SlicingWindowOperator<java.lang.Integer> slicingWindowOperator
private MemoryStateFactory stateFactory
public void setup()
public void inOrderTest()
public void inOrderTest2()
public void outOfOrderTestSimpleInsert()
public void outOfOrderTestRightInsert()
public void outOfOrderTestLeftInsert()
public void outOfOrderTestSplitSlice()
public void outOfOrderTestMergeSlice()
public void outOfOrderCombinedSessionTumblingMegeSession()
public void outOfOrderCombinedSessionMultiSession()