@Internal public static class PatternStream.CoMapTimeout<R,L> extends Object implements CoMapFunction<R,L,Either<L,R>>
Constructor and Description |
---|
CoMapTimeout() |
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.
|
public Either<L,R> map1(R value)
CoMapFunction
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.