Class | Description |
---|---|
AbstractKeyedCEPPatternOperator<IN,KEY,OUT,F extends Function> |
Abstract CEP pattern operator for a keyed input stream.
|
CEPOperatorUtils |
Utility methods for creating
PatternStream . |
FlatSelectCepOperator<IN,KEY,OUT> |
Version of
AbstractKeyedCEPPatternOperator that applies given PatternFlatSelectFunction to fully matched event patterns. |
FlatSelectTimeoutCepOperator<IN,OUT1,OUT2,KEY> |
Version of
AbstractKeyedCEPPatternOperator that applies given PatternFlatSelectFunction to fully
matched event patterns and PatternFlatTimeoutFunction to timed out ones. |
FlatSelectTimeoutCepOperator.FlatSelectWrapper<IN,OUT1,OUT2> |
Wrapper that enables storing
PatternFlatSelectFunction and PatternFlatTimeoutFunction functions
in one udf. |
SelectCepOperator<IN,KEY,OUT> |
Version of
AbstractKeyedCEPPatternOperator that applies given PatternSelectFunction to fully matched event patterns. |
SelectTimeoutCepOperator<IN,OUT1,OUT2,KEY> |
Version of
AbstractKeyedCEPPatternOperator that applies given PatternSelectFunction to fully
matched event patterns and PatternTimeoutFunction to timed out ones. |
SelectTimeoutCepOperator.SelectWrapper<IN,OUT1,OUT2> |
Wrapper that enables storing
PatternSelectFunction and PatternTimeoutFunction in one udf. |
StreamRecordComparator<IN> |
Compares two
StreamRecord s based on their timestamp. |
TimestampedSideOutputCollector<T> |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.