public interface FilteringInputPort extends EventHandlingInputPort
This is used as the interface for Processor input ports.
A condition to use this type is that the stream of events for a given process ID must terminate with a top level (i.e. zero length index array) token. This can be accomplished by use of the crystalizer (as found on the output of a Processor instance) or some other mechanism but is required. Similarly it is assumed that all intermediate collections are emited in the correct sequence, if this is not the case the filtering may not function correctly.
Modifier and Type | Method and Description |
---|---|
int |
getFilterDepth()
Set the depth at which to filter events.
|
getIncomingLink, receiveEvent
getAddAnnotationEdit, getAnnotations, getRemoveAnnotationEdit, setAnnotations
Copyright © 2015–2016 The Apache Software Foundation. All rights reserved.