Class MapPartitionIterator<IN>
- java.lang.Object
-
- org.apache.flink.streaming.api.operators.MapPartitionIterator<IN>
-
- All Implemented Interfaces:
Iterator<IN>
@Internal public class MapPartitionIterator<IN> extends Object implements Iterator<IN>
TheMapPartitionIterator
is an iterator used in theMapPartitionOperator
.The task main thread will add records to it. It will set itself as the input parameter ofMapPartitionFunction
and execute the function.
-
-
Field Summary
Fields Modifier and Type Field Description static int
DEFAULT_MAX_CACHE_NUM
Max number of caches.
-
Constructor Summary
Constructors Constructor Description MapPartitionIterator(Consumer<Iterator<IN>> udf)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addRecord(IN record)
void
close()
boolean
hasNext()
IN
next()
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface java.util.Iterator
forEachRemaining, remove
-
-
-
-
Field Detail
-
DEFAULT_MAX_CACHE_NUM
public static final int DEFAULT_MAX_CACHE_NUM
Max number of caches.The constant defines the maximum number of caches that can be created. Its value is set to 100, which is considered sufficient for most parallel jobs. Each cache is a record and occupies a minimal amount of memory so the value is not excessively large.
- See Also:
- Constant Field Values
-
-