Modifier and Type | Class and Description |
---|---|
class |
RichFlatMapFunction<IN,OUT>
Rich variant of the
FlatMapFunction . |
Modifier and Type | Class and Description |
---|---|
class |
FilterOperatorBase<T,FT extends FlatMapFunction<T,T>> |
class |
FlatMapOperatorBase<IN,OUT,FT extends FlatMapFunction<IN,OUT>> |
Modifier and Type | Class and Description |
---|---|
static class |
BulkIterationBase.TerminationCriterionMapper<X>
Special Mapper that is added before a termination criterion and is only a container for an special aggregator
|
Modifier and Type | Method and Description |
---|---|
<R> FlatMapOperator<T,R> |
DataSet.flatMap(FlatMapFunction<T,R> flatMapper)
Applies a FlatMap transformation on a
DataSet .The transformation calls a RichFlatMapFunction for each element of the DataSet. |
Modifier and Type | Class and Description |
---|---|
class |
FlatMapIterator<IN,OUT>
A convenience variant of the
RichFlatMapFunction that returns elements through an iterator, rather then
through a collector. |
Modifier and Type | Field and Description |
---|---|
protected FlatMapFunction<IN,OUT> |
FlatMapOperator.function |
Modifier and Type | Method and Description |
---|---|
protected FlatMapFunction<IN,OUT> |
FlatMapOperator.getFunction() |
Modifier and Type | Method and Description |
---|---|
protected FlatMapOperatorBase<IN,OUT,FlatMapFunction<IN,OUT>> |
FlatMapOperator.translateToDataFlow(Operator<IN> input) |
protected FilterOperatorBase<T,FlatMapFunction<T,T>> |
FilterOperator.translateToDataFlow(Operator<T> input) |
Constructor and Description |
---|
FlatMapOperator(DataSet<IN> input,
TypeInformation<OUT> resultType,
FlatMapFunction<IN,OUT> function,
String defaultName) |
Modifier and Type | Class and Description |
---|---|
static class |
PlanFilterOperator.FlatMapFilter<T> |
Modifier and Type | Method and Description |
---|---|
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getFlatMapReturnTypes(FlatMapFunction<IN,OUT> flatMapInterface,
TypeInformation<IN> inType) |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getFlatMapReturnTypes(FlatMapFunction<IN,OUT> flatMapInterface,
TypeInformation<IN> inType,
String functionName,
boolean allowMissing) |
Modifier and Type | Method and Description |
---|---|
<R> DataSet<R> |
DataSet.flatMap(FlatMapFunction<T,R> flatMapper,
TypeInformation<R> evidence$12,
scala.reflect.ClassTag<R> evidence$13)
Creates a new DataSet by applying the given function to every element and flattening
the results.
|
Modifier and Type | Class and Description |
---|---|
static class |
ConnectedComponents.UndirectEdge
Undirected edges by emitting for each input edge the input edges itself and an inverted version.
|
static class |
PageRank.JoinVertexWithEdgesMatch
Join function that distributes a fraction of a vertex's rank to all neighbors.
|
Modifier and Type | Class and Description |
---|---|
static class |
WordCount.Tokenizer
Implements the string tokenizer that splits sentences into words as a user-defined
FlatMapFunction.
|
static class |
WordCountPojo.Tokenizer
Implements the string tokenizer that splits sentences into words as a user-defined
FlatMapFunction.
|
Modifier and Type | Class and Description |
---|---|
class |
CompleteGraph.LinkVertexToAll |
class |
GridGraph.LinkVertexToNeighbors |
class |
StarGraph.LinkVertexToCenter |
Modifier and Type | Class and Description |
---|---|
class |
HadoopMapFunction<KEYIN,VALUEIN,KEYOUT,VALUEOUT>
This wrapper maps a Hadoop Mapper (mapred API) to a Flink FlatMapFunction.
|
Modifier and Type | Method and Description |
---|---|
Class<FlatMapFunction<IT,OT>> |
FlatMapDriver.getStubType() |
Modifier and Type | Method and Description |
---|---|
void |
FlatMapDriver.setup(TaskContext<FlatMapFunction<IT,OT>,OT> context) |
Modifier and Type | Class and Description |
---|---|
static class |
SpoutSourceWordCount.Tokenizer
Implements the string tokenizer that splits sentences into words as a user-defined FlatMapFunction.
|
Modifier and Type | Method and Description |
---|---|
<R> SingleOutputStreamOperator<R> |
DataStream.flatMap(FlatMapFunction<T,R> flatMapper)
Applies a FlatMap transformation on a
DataStream . |
Modifier and Type | Class and Description |
---|---|
class |
FileReadFunction
Deprecated.
|
Constructor and Description |
---|
StreamFlatMap(FlatMapFunction<IN,OUT> flatMapper) |
Modifier and Type | Method and Description |
---|---|
<R> DataStream<R> |
DataStream.flatMap(FlatMapFunction<T,R> flatMapper,
TypeInformation<R> evidence$8)
Creates a new DataStream by applying the given function to every element and flattening
the results.
|
Modifier and Type | Class and Description |
---|---|
static class |
TwitterExample.SelectEnglishAndTokenizeFlatMap
Deserialize JSON from twitter source
|
Modifier and Type | Class and Description |
---|---|
static class |
PojoExample.Tokenizer
Implements the string tokenizer that splits sentences into words as a
user-defined FlatMapFunction.
|
Modifier and Type | Method and Description |
---|---|
GeneratedFunction<FlatMapFunction<Object,Object>> |
FlinkCorrelate.generateFunction(TableConfig config,
TypeInformation<Object> inputTypeInfo,
TypeInformation<Object> udtfTypeInfo,
TypeInformation<Object> returnType,
org.apache.calcite.rel.type.RelDataType rowType,
org.apache.calcite.sql.SemiJoinType joinType,
org.apache.calcite.rex.RexCall rexCall,
scala.Option<int[]> pojoFieldMapping,
String ruleDescription)
Generates the flat map function to run the user-defined table function.
|
Modifier and Type | Method and Description |
---|---|
RichFlatMapFunction<Object,Object> |
FlinkCalc.calcMapFunction(GeneratedFunction<FlatMapFunction<Object,Object>> genFunction) |
Modifier and Type | Class and Description |
---|---|
class |
CorrelateFlatMapRunner<IN,OUT> |
class |
FlatMapRunner<IN,OUT> |
class |
MapJoinLeftRunner<IN1,IN2,OUT> |
class |
MapJoinRightRunner<IN1,IN2,OUT> |
class |
MapSideJoinRunner<IN1,IN2,SINGLE_IN,MULTI_IN,OUT> |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.