org.apache.flink.cep

Class PatternStream.CoMapTimeout<R,L>

java.lang.Object

org.apache.flink.cep.PatternStream.CoMapTimeout<R,L>

All Implemented Interfaces:

Serializable, Function, CoMapFunction<R,L,Either<L,R>>

Enclosing class:

PatternStream<T>

@Internal
public static class PatternStream.CoMapTimeout<R,L>
extends Object
implements CoMapFunction<R,L,Either<L,R>>

Used for joining results from timeout side-output for API backward compatibility.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CoMapTimeout()

Method Summary

Modifier and Type	Method and Description
Either<L,R>	map1(R value) This method is called for each element in the first of the connected streams.
Either<L,R>	map2(L value) This method is called for each element in the second of the connected streams.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CoMapTimeout

public CoMapTimeout()

Method Detail

map1

public Either<L,R> map1(R value)

Description copied from interface: CoMapFunction

This method is called for each element in the first of the connected streams.

Specified by:

map1 in interface CoMapFunction<R,L,Either<L,R>>

Parameters:

value - The stream element

Returns:

The resulting element

map2

public Either<L,R> map2(L value)

Description copied from interface: CoMapFunction

This method is called for each element in the second of the connected streams.

Specified by:

map2 in interface CoMapFunction<R,L,Either<L,R>>

Parameters:

value - The stream element

Returns:

The resulting element