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 . |
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 | 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 |
---|---|
static class |
BinaryResult.MirrorResult<T,RT extends BinaryResult<T>>
Output each input and a second result with the vertex order flipped.
|
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 | 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.
Internal class deprecated in favour of
ContinuousFileMonitoringFunction . |
Constructor and Description |
---|
StreamFlatMap(FlatMapFunction<IN,OUT> flatMapper) |
Modifier and Type | Class and Description |
---|---|
static class |
TwitterExample.SelectEnglishAndTokenizeFlatMap
Deserialize JSON from twitter source
|
Modifier and Type | Method and Description |
---|---|
PythonDataStream<SingleOutputStreamOperator<org.python.core.PyObject>> |
PythonDataStream.flat_map(FlatMapFunction<org.python.core.PyObject,Object> flat_mapper)
A thin wrapper layer over
DataStream.flatMap(FlatMapFunction) . |
Modifier and Type | Class and Description |
---|---|
class |
PythonFlatMapFunction
The
PythonFlatMapFunction is a thin wrapper layer over a Python UDF FlatMapFunction . |
Constructor and Description |
---|
PythonFlatMapFunction(FlatMapFunction<org.python.core.PyObject,Object> fun) |
Modifier and Type | Class and Description |
---|---|
class |
SemanticsCheckMapper
This mapper validates exactly-once and at-least-once semantics in connection with
SequenceGeneratorSource . |
class |
SlidingWindowCheckMapper
This mapper validates sliding event time window.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.