Interface | Description |
---|---|
EventComparator<T> |
Custom comparator used to compares two events.
|
PatternFlatSelectFunction<IN,OUT> |
Base interface for a pattern select function which can produce multiple resulting elements.
|
PatternFlatTimeoutFunction<IN,OUT> |
Base interface for a pattern timeout function which can produce multiple resulting elements.
|
PatternSelectFunction<IN,OUT> |
Base interface for a pattern select function.
|
PatternTimeoutFunction<IN,OUT> |
Base interface for a pattern timeout function.
|
Class | Description |
---|---|
CEP |
Utility class for complex event processing.
|
NonDuplicatingTypeSerializer<T> |
Type serializer which keeps track of the serialized objects so that each object is only
serialized once.
|
PatternStream<T> |
Stream abstraction for CEP pattern detection.
|
PatternStream.CoMapTimeout<R,L> |
Used for joining results from timeout side-output for API backward compatibility.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.