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