stores consecutive offsets and lengths of blocks into each reducer file , ordered by position in the file . note : mapidtoindex mapid returns the index of the mapper into the vector for every reducer . concode_field_sep PlaceHolder placeHolder concode_field_sep org.apache.spark.util.TimeStampedHashMap<java.lang.Object,org.apache.spark.shuffle.FileShuffleBlockManager.ShuffleState> shuffleStates concode_elem_sep java.util.concurrent.ConcurrentLinkedQueue<org.apache.spark.shuffle.FileShuffleBlockManager.ShuffleFileGroup> allFileGroups concode_elem_sep scala.Option<org.apache.spark.storage.FileSegment> getFileSegmentFor concode_elem_sep java.util.concurrent.ConcurrentLinkedQueue<java.lang.Object> completedMapTasks concode_elem_sep org.apache.spark.network.buffer.ManagedBuffer getBlockData concode_elem_sep boolean removeShuffleBlocks concode_elem_sep org.apache.spark.storage.BlockManager blockManager concode_elem_sep scala.Option<java.nio.ByteBuffer> getBytes concode_elem_sep java.util.concurrent.atomic.AtomicInteger nextFileId concode_elem_sep java.util.concurrent.ConcurrentLinkedQueue<org.apache.spark.shuffle.FileShuffleBlockManager.ShuffleFileGroup> unusedFileGroups concode_elem_sep boolean removeShuffle concode_elem_sep org.apache.spark.util.collection.PrimitiveKeyOpenHashMap<java.lang.Object,java.lang.Object> mapIdToIndex concode_elem_sep org.apache.spark.util.collection.PrimitiveVector<java.lang.Object>[] blockLengthsByReducer concode_elem_sep org.apache.spark.util.MetadataCleaner metadataCleaner concode_elem_sep java.io.File apply concode_elem_sep void recordMapOutput concode_elem_sep int numBlocks concode_elem_sep void stop concode_elem_sep java.lang.Object forMapTask concode_elem_sep void cleanup concode_elem_sep boolean consolidateShuffleFiles concode_elem_sep java.io.File[] files concode_elem_sep int shuffleId concode_elem_sep java.lang.String physicalFileName concode_elem_sep org.apache.spark.network.util.TransportConf transportConf concode_elem_sep int numBuckets concode_elem_sep int fileId concode_elem_sep int bufferSize
org . apache . spark . util . collection . PrimitiveVector < java . lang . Object > [ ] function ( ) { throw new RuntimeException ( ) ; }