public void endBuild ( ) throws IOException { // finalize the partitions int buildWriteBuffers = 0 ; for ( BinaryHashPartition p : this . partitionsBeingBuilt ) { buildWriteBuffers += p . finalizeBuildPhase ( this . ioManager , this . currentEnumerator ) ; } buildSpillRetBufferNumbers += buildWriteBuffers ; // the first prober is the probe-side input, but the input is null at beginning this . probeIterator = new ProbeIterator ( this . binaryProbeSideSerializer . createInstance ( ) ) ; // the bucket iterator can remain constant over the time this . bucketIterator = new LookupBucketIterator ( this ) ; }
End build phase .