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 |
---|---|
CoProcessFunction<IN1,IN2,OUT> |
A function that processes elements of two streams and produces a single output one.
|
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–2018 The Apache Software Foundation. All rights reserved.