IN
- The type of the data set consumed by the operator.OUT
- The type of the data set created by the operator.@Public public class FlatMapOperator<IN,OUT> extends SingleInputUdfOperator<IN,OUT,FlatMapOperator<IN,OUT>>
Modifier and Type | Field and Description |
---|---|
protected String |
defaultName |
protected FlatMapFunction<IN,OUT> |
function |
name, parallelism
Constructor and Description |
---|
FlatMapOperator(DataSet<IN> input,
TypeInformation<OUT> resultType,
FlatMapFunction<IN,OUT> function,
String defaultName) |
Modifier and Type | Method and Description |
---|---|
protected FlatMapFunction<IN,OUT> |
getFunction() |
protected FlatMapOperatorBase<IN,OUT,FlatMapFunction<IN,OUT>> |
translateToDataFlow(Operator<IN> input)
Translates this operation to a data flow operator of the common data flow API.
|
extractSemanticAnnotations, getAnalyzedUdfSemanticsFlag, getBroadcastSets, getParameters, getSemanticProperties, returns, returns, returns, returns, setAnalyzedUdfSemanticsFlag, setSemanticProperties, udfWithForwardedFieldsAnnotation, withBroadcastSet, withForwardedFields, withParameters
getInput, getInputType
getName, getParallelism, getResultType, name, setParallelism
aggregate, checkSameExecutionContext, clean, coGroup, collect, combineGroup, count, cross, crossWithHuge, crossWithTiny, distinct, distinct, distinct, distinct, fillInType, filter, first, flatMap, fullOuterJoin, fullOuterJoin, getExecutionEnvironment, getType, groupBy, groupBy, groupBy, iterate, iterateDelta, join, join, joinWithHuge, joinWithTiny, leftOuterJoin, leftOuterJoin, map, mapPartition, max, maxBy, min, minBy, output, partitionByHash, partitionByHash, partitionByHash, partitionByRange, partitionByRange, partitionByRange, partitionCustom, partitionCustom, partitionCustom, print, print, printOnTaskManager, printToErr, printToErr, project, rebalance, reduce, reduceGroup, rightOuterJoin, rightOuterJoin, runOperation, sortPartition, sortPartition, sortPartition, sum, union, write, write, writeAsCsv, writeAsCsv, writeAsCsv, writeAsCsv, writeAsFormattedText, writeAsFormattedText, writeAsText, writeAsText
protected final FlatMapFunction<IN,OUT> function
protected final String defaultName
public FlatMapOperator(DataSet<IN> input, TypeInformation<OUT> resultType, FlatMapFunction<IN,OUT> function, String defaultName)
protected FlatMapFunction<IN,OUT> getFunction()
getFunction
in class SingleInputUdfOperator<IN,OUT,FlatMapOperator<IN,OUT>>
protected FlatMapOperatorBase<IN,OUT,FlatMapFunction<IN,OUT>> translateToDataFlow(Operator<IN> input)
SingleInputOperator
translateToDataFlow
in class SingleInputOperator<IN,OUT,FlatMapOperator<IN,OUT>>
input
- The data flow operator that produces this operation's input data.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.