org.apache.flink.streaming.api.operators

类 MapPartitionIterator<IN>

java.lang.Object

org.apache.flink.streaming.api.operators.MapPartitionIterator<IN>

所有已实现的接口:

Iterator<IN>

@Internal
public class MapPartitionIterator<IN>
extends Object
implements Iterator<IN>

The MapPartitionIterator is an iterator used in the MapPartitionOperator.The task main thread will add records to it. It will set itself as the input parameter of MapPartitionFunction and execute the function.

字段概要

字段

限定符和类型	字段和说明
static int	DEFAULT_MAX_CACHE_NUM Max number of caches.

构造器概要

构造器

构造器和说明
MapPartitionIterator(Consumer<Iterator<IN>> udf)

方法概要

限定符和类型	方法和说明
void	addRecord(IN record)
void	close()
boolean	hasNext()
IN	next()

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 java.util.Iterator

forEachRemaining, remove

字段详细资料

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.

另请参阅:

常量字段值

构造器详细资料

MapPartitionIterator

public MapPartitionIterator(Consumer<Iterator<IN>> udf)

方法详细资料

hasNext

public boolean hasNext()

指定者:

hasNext 在接口中 Iterator<IN>

next

public IN next()

指定者:

next 在接口中 Iterator<IN>

addRecord

public void addRecord(IN record)

close

public void close()