Class HashPartitionIterator<BT,PT>
- java.lang.Object
-
- org.apache.flink.runtime.iterative.io.HashPartitionIterator<BT,PT>
-
- Type Parameters:
BT
-
- All Implemented Interfaces:
MutableObjectIterator<BT>
public class HashPartitionIterator<BT,PT> extends Object implements MutableObjectIterator<BT>
Iterator
over the build side entries of aHashPartition
.
-
-
Constructor Summary
Constructors Constructor Description HashPartitionIterator(Iterator<HashPartition<BT,PT>> partitions, TypeSerializer<BT> serializer)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description BT
next()
Gets the next element from the collection.BT
next(BT reuse)
Gets the next element from the collection.
-
-
-
Constructor Detail
-
HashPartitionIterator
public HashPartitionIterator(Iterator<HashPartition<BT,PT>> partitions, TypeSerializer<BT> serializer)
-
-
Method Detail
-
next
public BT next(BT reuse) throws IOException
Description copied from interface:MutableObjectIterator
Gets the next element from the collection. The contents of that next element is put into the given reuse object, if the type is mutable.- Specified by:
next
in interfaceMutableObjectIterator<BT>
- Parameters:
reuse
- The target object into which to place next element if E is mutable.- Returns:
- The filled object or
null
if the iterator is exhausted. - Throws:
IOException
- Thrown, if a problem occurred in the underlying I/O layer or in the serialization / deserialization logic
-
next
public BT next() throws IOException
Description copied from interface:MutableObjectIterator
Gets the next element from the collection. The iterator implementation must obtain a new instance.- Specified by:
next
in interfaceMutableObjectIterator<BT>
- Returns:
- The object or
null
if the iterator is exhausted. - Throws:
IOException
- Thrown, if a problem occurred in the underlying I/O layer or in the serialization / deserialization logic
-
-