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.
|
CoProcessFunction<IN1,IN2,OUT> |
A function that processes elements of two streams and produces a single output one.
|
CoProcessFunction.Context |
Information available in an invocation of
CoProcessFunction.processElement1(Object, Context, Collector) /
CoProcessFunction.processElement2(Object, Context, Collector)
or CoProcessFunction.onTimer(long, OnTimerContext, Collector) . |
CoProcessFunction.OnTimerContext |
Information available in an invocation of
CoProcessFunction.onTimer(long, OnTimerContext, Collector) . |
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.
|
RichCoProcessFunction<IN1,IN2,OUT> |
Rich variant of the
CoProcessFunction . |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.