Class 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 Detail

      • CoMapTimeout

        public CoMapTimeout()
    • Method Detail

      • map1

        public org.apache.flink.types.Either<L,​R> map1​(R value)
        Specified by:
        map1 in interface org.apache.flink.streaming.api.functions.co.CoMapFunction<R,​L,​org.apache.flink.types.Either<L,​R>>
      • map2

        public org.apache.flink.types.Either<L,​R> map2​(L value)
        Specified by:
        map2 in interface org.apache.flink.streaming.api.functions.co.CoMapFunction<R,​L,​org.apache.flink.types.Either<L,​R>>