Interface | Description |
---|---|
CoFlatMapFunction<IN1,IN2,OUT> |
A CoFlatMapFunction implements a flat-map transformation over two
connected streams.
|
CoMapFunction<IN1,IN2,OUT> |
A CoFlatMapFunction implements a map() transformation over two
connected streams.
|
Class | Description |
---|---|
RichCoFlatMapFunction<IN1,IN2,OUT> |
A RichCoFlatMapFunction represents a FlatMap transformation with two different input
types.
|
RichCoMapFunction<IN1,IN2,OUT> |
A RichCoMapFunction represents a Map transformation with two different input
types.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.