public class FilterHandler extends Object implements StreamHandler
Constructor and Description |
---|
FilterHandler(ConditionExecutor conditionExecutor,
List<QueryEventStream> queryEventStreamList) |
Modifier and Type | Method and Description |
---|---|
String |
getStreamId() |
SchedulerQueue<StreamEvent> |
getWindow() |
void |
process(ComplexEvent complexEvent) |
void |
setNext(StreamProcessor nextPreStreamFlowProcessor) |
void |
setPrevious(StreamElement streamElement) |
public FilterHandler(ConditionExecutor conditionExecutor, List<QueryEventStream> queryEventStreamList)
public void process(ComplexEvent complexEvent)
process
in interface StreamProcessor
public void setNext(StreamProcessor nextPreStreamFlowProcessor)
setNext
in interface StreamHandler
public void setPrevious(StreamElement streamElement)
setPrevious
in interface StreamProcessor
public String getStreamId()
getStreamId
in interface StreamElement
public SchedulerQueue<StreamEvent> getWindow()
getWindow
in interface StreamElement
Copyright © 2012. All Rights Reserved.