public class WindowManagerTest
extends java.lang.Object
| Constructor and Description |
|---|
WindowManagerTest() |
| Modifier and Type | Method and Description |
|---|---|
void |
generateAutoMockData() |
void |
generateMockData() |
void |
setUp() |
void |
tearDown() |
void |
testCountBasedSlidingWithSameEventTs() |
void |
testCountBasedTriggerWithEventTs() |
void |
testCountBasedTumblingWithSameEventTs() |
void |
testCountBasedWindow() |
void |
testCountBasedWindowWithEventTs() |
void |
testEventTimeBasedWindow() |
void |
testEventTimeLag() |
void |
testExpireThreshold() |
void |
testExpireThresholdWithWatermarkCountEvictionPolicy() |
void |
testScanStop() |
void |
testTumblingWindow() |
public void setUp()
public void tearDown()
public void generateMockData()
public void generateAutoMockData()
public void testCountBasedWindow()
throws java.lang.Exception
java.lang.Exceptionpublic void testTumblingWindow()
throws java.lang.Exception
java.lang.Exceptionpublic void testEventTimeBasedWindow()
throws java.lang.Exception
java.lang.Exceptionpublic void testCountBasedWindowWithEventTs()
throws java.lang.Exception
java.lang.Exceptionpublic void testCountBasedTriggerWithEventTs()
throws java.lang.Exception
java.lang.Exceptionpublic void testCountBasedTumblingWithSameEventTs()
throws java.lang.Exception
java.lang.Exceptionpublic void testCountBasedSlidingWithSameEventTs()
throws java.lang.Exception
java.lang.Exceptionpublic void testEventTimeLag()
throws java.lang.Exception
java.lang.Exceptionpublic void testScanStop()
throws java.lang.Exception
java.lang.Exceptionpublic void testExpireThreshold()
throws java.lang.Exception
java.lang.Exceptionpublic void testExpireThresholdWithWatermarkCountEvictionPolicy()
throws java.lang.Exception
java.lang.Exception