|
Change Parameter Type futures : Collection<Future<Void>> to futures : Collection<Future<BlockReadStats>> in method private cancelReads(futures Collection<Future<BlockReadStats>>) : void in class org.apache.hadoop.hdfs.server.datanode.erasurecode.StripedReader |
From |
To |
|
Change Parameter Type readService : CompletionService<Void> to readService : CompletionService<BlockReadStats> in method public getNextCompletedStripedRead(readService CompletionService<BlockReadStats>, futures Map<Future<BlockReadStats>,Integer>, timeoutMillis long) : StripingChunkReadResult in class org.apache.hadoop.hdfs.util.StripedBlockUtil |
From |
To |
|
Change Parameter Type futures : Map<Future<Void>,Integer> to futures : Map<Future<BlockReadStats>,Integer> in method public getNextCompletedStripedRead(readService CompletionService<BlockReadStats>, futures Map<Future<BlockReadStats>,Integer>, timeoutMillis long) : StripingChunkReadResult in class org.apache.hadoop.hdfs.util.StripedBlockUtil |
From |
To |
|
Change Return Type CompletionService<Void> to CompletionService<BlockReadStats> in method package createReadService() : CompletionService<BlockReadStats> in class org.apache.hadoop.hdfs.server.datanode.erasurecode.StripedReconstructor |
From |
To |
|
Change Return Type CompletionService<Void> to CompletionService<BlockReadStats> in method package createReadService() : CompletionService<BlockReadStats> in class org.apache.hadoop.hdfs.server.datanode.erasurecode.ErasureCodingWorker |
From |
To |
|
Change Return Type void to BlockReadStats in method private actualReadFromBlock() : BlockReadStats in class org.apache.hadoop.hdfs.server.datanode.erasurecode.StripedBlockReader |
From |
To |
|
Change Return Type Callable<Void> to Callable<BlockReadStats> in method package readFromBlock(length int, corruptedBlocks CorruptedBlocks) : Callable<BlockReadStats> in class org.apache.hadoop.hdfs.server.datanode.erasurecode.StripedBlockReader |
From |
To |
|
Change Return Type Callable<Void> to Callable<BlockReadStats> in method private readCells(reader BlockReader, datanode DatanodeInfo, currentReaderOffset long, targetReaderOffset long, strategies ByteBufferStrategy[], currentBlock ExtendedBlock) : Callable<BlockReadStats> in class org.apache.hadoop.hdfs.StripeReader |
From |
To |
|
Change Variable Type future : Future<Void> to future : Future<BlockReadStats> in method public getNextCompletedStripedRead(readService CompletionService<BlockReadStats>, futures Map<Future<BlockReadStats>,Integer>, timeoutMillis long) : StripingChunkReadResult in class org.apache.hadoop.hdfs.util.StripedBlockUtil |
From |
To |
|
Change Variable Type future : Future<Void> to future : Future in method package clearFutures() : void in class org.apache.hadoop.hdfs.StripeReader |
From |
To |
|
Change Variable Type f : Future<Void> to f : Future<BlockReadStats> in method package doReadMinimumSources(reconstructLength int, corruptedBlocks CorruptedBlocks) : int[] in class org.apache.hadoop.hdfs.server.datanode.erasurecode.StripedReader |
From |
To |
|
Change Variable Type readCallable : Callable<Void> to readCallable : Callable<BlockReadStats> in method package doReadMinimumSources(reconstructLength int, corruptedBlocks CorruptedBlocks) : int[] in class org.apache.hadoop.hdfs.server.datanode.erasurecode.StripedReader |
From |
To |
|
Change Variable Type readCallable : Callable<Void> to readCallable : Callable<BlockReadStats> in method package readChunk(block LocatedBlock, chunkIndex int) : boolean in class org.apache.hadoop.hdfs.StripeReader |
From |
To |
|
Change Variable Type f : Future<Void> to f : Future<BlockReadStats> in method private scheduleNewRead(used BitSet, reconstructLength int, corruptedBlocks CorruptedBlocks) : int in class org.apache.hadoop.hdfs.server.datanode.erasurecode.StripedReader |
From |
To |
|
Change Variable Type future : Future<Void> to future : Future<BlockReadStats> in method private cancelReads(futures Collection<Future<BlockReadStats>>) : void in class org.apache.hadoop.hdfs.server.datanode.erasurecode.StripedReader |
From |
To |
|
Change Variable Type readCallable : Callable<Void> to readCallable : Callable<BlockReadStats> in method private scheduleNewRead(used BitSet, reconstructLength int, corruptedBlocks CorruptedBlocks) : int in class org.apache.hadoop.hdfs.server.datanode.erasurecode.StripedReader |
From |
To |
|
Change Variable Type request : Future<Void> to request : Future<BlockReadStats> in method package readChunk(block LocatedBlock, chunkIndex int) : boolean in class org.apache.hadoop.hdfs.StripeReader |
From |
To |