Package org.apache.flink.cep
Class PatternStream.CoMapTimeout<R,L>
- java.lang.Object
-
- org.apache.flink.cep.PatternStream.CoMapTimeout<R,L>
-
- All Implemented Interfaces:
Serializable,org.apache.flink.api.common.functions.Function,org.apache.flink.streaming.api.functions.co.CoMapFunction<R,L,org.apache.flink.types.Either<L,R>>
- Enclosing class:
- PatternStream<T>
@Internal public static class PatternStream.CoMapTimeout<R,L> extends Object implements org.apache.flink.streaming.api.functions.co.CoMapFunction<R,L,org.apache.flink.types.Either<L,R>>
Used for joining results from timeout side-output for API backward compatibility.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description CoMapTimeout()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.flink.types.Either<L,R>map1(R value)org.apache.flink.types.Either<L,R>map2(L value)
-