Java源码示例：org.apache.flink.runtime.operators.hash.HashPartition
示例1
public HashPartitionIterator(Iterator<HashPartition<BT, PT>> partitions, TypeSerializer<BT> serializer) {
this.partitions = partitions;
this.serializer = serializer;
currentPartition = null;
}
示例2
public HashPartitionIterator(Iterator<HashPartition<BT, PT>> partitions, TypeSerializer<BT> serializer) {
this.partitions = partitions;
this.serializer = serializer;
currentPartition = null;
}
示例3
public HashPartitionIterator(Iterator<HashPartition<BT, PT>> partitions, TypeSerializer<BT> serializer) {
this.partitions = partitions;
this.serializer = serializer;
currentPartition = null;
}
