public class MapJoinRightRunner<IN1,IN2,OUT> extends MapSideJoinRunner<IN1,IN2,IN1,IN2,OUT>
Constructor and Description |
---|
MapJoinRightRunner(String name,
String code,
boolean outerJoin,
TypeInformation<OUT> returnType,
String broadcastSetName) |
Modifier and Type | Method and Description |
---|---|
void |
flatMap(IN2 multiInput,
Collector<OUT> out)
The core method of the FlatMapFunction.
|
broadcastSet, function, getProducedType, open, returnType
close, getIterationRuntimeContext, getRuntimeContext, setRuntimeContext
public MapJoinRightRunner(String name, String code, boolean outerJoin, TypeInformation<OUT> returnType, String broadcastSetName)
public void flatMap(IN2 multiInput, Collector<OUT> out)
FlatMapFunction
flatMap
in interface FlatMapFunction<IN2,OUT>
flatMap
in class RichFlatMapFunction<IN2,OUT>
multiInput
- The input value.out
- The collector for returning result values.Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.