IN
- OUT
- public interface PatternFlatTimeoutFunction<IN,OUT> extends Function, Serializable
Pattern
specifying the sought-after pattern. Additionally, a
collector is provided as a parameter. The collector is used to emit an arbitrary number of
resulting elements.
PatternStream<IN> pattern = ...
DataStream<OUT> result = pattern.flatSelect(..., new MyPatternFlatTimeoutFunction());
Modifier and Type | Method and Description |
---|---|
void |
timeout(Map<String,List<IN>> pattern,
long timeoutTimestamp,
Collector<OUT> out)
Generates zero or more resulting timeout elements given a map of partial pattern events and
the timestamp of the timeout.
|
void timeout(Map<String,List<IN>> pattern, long timeoutTimestamp, Collector<OUT> out) throws Exception
pattern
- Map containing the partial pattern. Events are identified by their names.timeoutTimestamp
- Timestamp when the timeout occurredout
- Collector used to output the generated elementsException
- This method may throw exceptions. Throwing an exception will cause the
operation to fail and may trigger recovery.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.