基于Spark Shuffle Block的优化

org.apache.spark.storage.DiskStore   if(length<minMemoryMapBytes){   valbuf=ByteBuffer.allocate(length.toInt)   channel.position(offset)   while(buf.remaining()!=0){   if(channel.read(buf)==-1){   thr

>>阅读原文<<