T
- The type of the event.public class EventOperatorBase<T> extends java.lang.Object implements EventOperator<T>
Constructor and Description |
---|
EventOperatorBase(java.util.function.Predicate<EventsArray<? extends T>> predicate) |
Modifier and Type | Method and Description |
---|---|
Restore |
start(java.util.List<? extends EventSource<? extends T>> nodes,
java.util.function.Consumer<? super CompositeEvent<T>> results) |
public EventOperatorBase(java.util.function.Predicate<EventsArray<? extends T>> predicate)
public Restore start(java.util.List<? extends EventSource<? extends T>> nodes, java.util.function.Consumer<? super CompositeEvent<T>> results) throws java.lang.Exception
start
in interface EventOperator<T>
java.lang.Exception