Pattern matching - fanhubgt/StreamEPS GitHub Wiki

Average. This is a test case for pattern matching an unbound stream of event using an average pattern parameter.

public class AvgPatternTest extends TestCase {                                 

    public AvgPatternTest(String testName) {
        super(testName);
    }

    public void testThresholdAvgPE() {                                       
        ThresholdAveragePE averagePE = new ThresholdAveragePE();
        averagePE.setDispatcher(new TestDispatcher());
        averagePE.getMatchListeners().add(new TestPatternMatchListener());              
        PatternParameter pp = new PatternParameter("value", ">=", 6.0);                                 
        averagePE.getParameters().add(pp);                                           
        for (int i = 0; i < 50; i++) {                                                                                  
            TestEvent event = new TestEvent("E" + i, (double) i);                   
            averagePE.processEvent(event);                                                      
            if (i % 5 == 0) {
                averagePE.output();                                              
            }
        }
    }
}