Package | Description |
---|---|
org.apache.flink.api.java.functions | |
org.apache.flink.hadoopcompatibility.mapred | |
org.apache.flink.streaming.tests |
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 |
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.