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 | Class and Description |
---|---|
class |
HadoopMapFunction<KEYIN,VALUEIN,KEYOUT,VALUEOUT>
This wrapper maps a Hadoop Mapper (mapred API) to a Flink FlatMapFunction.
|
Modifier and Type | Class and Description |
---|---|
class |
JSONParseFlatMap<IN,OUT>
Abstract class derived from
RichFlatMapFunction to handle JSON files. |
Modifier and Type | Class and Description |
---|---|
static class |
TwitterStreaming.SelectDataFlatMap |
static class |
TwitterTopology.SelectLanguageFlatMap
FlatMapFunction to determine the language of tweets if possible
|
Modifier and Type | Class and Description |
---|---|
static class |
TwitterStream.SelectEnglishAndTokenizeFlatMap
Makes sentences from English tweets.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.