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<?>> predicate) |
| Modifier and Type | Method and Description |
|---|---|
Restore |
start(java.util.List<? extends EventSource<?>> nodes,
java.util.function.Consumer<? super CompositeEvent<T>> results) |
public EventOperatorBase(java.util.function.Predicate<EventsArray<?>> predicate)
public Restore start(java.util.List<? extends EventSource<?>> nodes, java.util.function.Consumer<? super CompositeEvent<T>> results)
start in interface EventOperator<T>