|
Move And Rename Method package ReplicaInPipeline(blockId long, len long, genStamp long, vol FsVolumeSpi, dir File, writer Thread, bytesToReserve long) from class org.apache.hadoop.hdfs.server.datanode.ReplicaInPipeline to package LocalReplicaInPipeline(blockId long, len long, genStamp long, vol FsVolumeSpi, dir File, writer Thread, bytesToReserve long) from class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline |
From |
To |
|
Move And Rename Method public ReplicaInPipeline(from ReplicaInPipeline) from class org.apache.hadoop.hdfs.server.datanode.ReplicaInPipeline to public LocalReplicaInPipeline(from LocalReplicaInPipeline) from class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline |
From |
To |
|
Move And Rename Method package ReplicaInPipeline(block Block, vol FsVolumeSpi, dir File, writer Thread) from class org.apache.hadoop.hdfs.server.datanode.ReplicaInPipeline to package LocalReplicaInPipeline(block Block, vol FsVolumeSpi, dir File, writer Thread) from class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline |
From |
To |
|
Move And Rename Method public ReplicaInPipeline(blockId long, genStamp long, vol FsVolumeSpi, dir File, bytesToReserve long) from class org.apache.hadoop.hdfs.server.datanode.ReplicaInPipeline to public LocalReplicaInPipeline(blockId long, genStamp long, vol FsVolumeSpi, dir File, bytesToReserve long) from class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline |
From |
To |
|
Change Parameter Type f : File to replicaInfo : ReplicaInfo in method package addFinalizedBlock(bpid String, b Block, replicaInfo ReplicaInfo, bytesReserved long) : ReplicaInfo in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsVolumeImpl |
From |
To |
|
Change Parameter Type rbw : ReplicaBeingWritten to rbw : ReplicaInPipeline in method private recoverRbwImpl(rbw ReplicaInPipeline, b ExtendedBlock, newGS long, minBytesRcvd long, maxBytesRcvd long) : ReplicaHandler in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Change Parameter Type blockFile : File to replicaToDelete : ReplicaInfo in method package ReplicaFileDeleteTask(volumeRef FsVolumeReference, replicaToDelete ReplicaInfo, block ExtendedBlock, trashDirectory String) in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetAsyncDiskService.ReplicaFileDeleteTask |
From |
To |
|
Change Parameter Type rur : ReplicaUnderRecovery to rur : ReplicaInfo in method private updateReplicaUnderRecovery(bpid String, rur ReplicaInfo, recoveryId long, newBlockId long, newlength long) : ReplicaInfo in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Change Parameter Type replicaInfo : ReplicaUnderRecovery to replicaInfo : ReplicaInfo in method private copyReplicaWithNewBlockIdAndGS(replicaInfo ReplicaInfo, bpid String, newBlkId long, newGS long) : File[] in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsVolumeImpl |
From |
To |
|
Change Parameter Type from : ReplicaInPipeline to from : LocalReplicaInPipeline in method public LocalReplicaInPipeline(from LocalReplicaInPipeline) in class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline |
From |
To |
|
Change Parameter Type from : ReplicaInfo to from : LocalReplica in method package LocalReplica(from LocalReplica) in class org.apache.hadoop.hdfs.server.datanode.LocalReplica |
From |
To |
|
Change Parameter Type rbw : ReplicaBeingWritten to rbw : ReplicaInPipeline in method private waitForMinLength(rbw ReplicaInPipeline, len long) : void in class org.apache.hadoop.hdfs.server.datanode.BlockSender |
From |
To |
|
Change Parameter Type replica : ReplicaInPipelineInterface to replica : ReplicaInPipeline in method public ReplicaHandler(replica ReplicaInPipeline, reference FsVolumeReference) in class org.apache.hadoop.hdfs.server.datanode.ReplicaHandler |
From |
To |
|
Change Parameter Type f : File to replicaInfo : ReplicaInfo in method package addFinalizedBlock(b Block, replicaInfo ReplicaInfo) : File in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.BlockPoolSlice |
From |
To |
|
Change Parameter Type blockFile : File to replicaInfo : ReplicaInfo in method package ReplicaLazyPersistTask(bpId String, blockId long, genStamp long, creationTime long, replicaInfo ReplicaInfo, targetVolume FsVolumeReference, lazyPersistDir File) in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.RamDiskAsyncLazyPersistService.ReplicaLazyPersistTask |
From |
To |
|
Change Parameter Type srcfile : File to replicaInfo : ReplicaInfo in method package moveBlockFiles(b Block, replicaInfo ReplicaInfo, destdir File) : File in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Change Parameter Type blockFile : File to info : ReplicaInfo in method public getTrashDirectoryForReplica(bpid String, info ReplicaInfo) : String in class org.apache.hadoop.hdfs.server.datanode.DataStorage |
From |
To |
|
Push Down Attribute private hasSubdirs : boolean from class org.apache.hadoop.hdfs.server.datanode.ReplicaInfo to private hasSubdirs : boolean from class org.apache.hadoop.hdfs.server.datanode.LocalReplica |
From |
To |
|
Push Down Attribute private baseDir : File from class org.apache.hadoop.hdfs.server.datanode.ReplicaInfo to private baseDir : File from class org.apache.hadoop.hdfs.server.datanode.LocalReplica |
From |
To |
|
Push Down Attribute private bytesReserved : long from class org.apache.hadoop.hdfs.server.datanode.ReplicaInPipeline to private bytesReserved : long from class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline |
From |
To |
|
Push Down Attribute private writer : AtomicReference<Thread> from class org.apache.hadoop.hdfs.server.datanode.ReplicaInPipeline to private writer : AtomicReference<Thread> from class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline |
From |
To |
|
Push Down Attribute private originalBytesReserved : long from class org.apache.hadoop.hdfs.server.datanode.ReplicaInPipeline to private originalBytesReserved : long from class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline |
From |
To |
|
Push Down Attribute private lastChecksum : byte[] from class org.apache.hadoop.hdfs.server.datanode.ReplicaInPipeline to private lastChecksum : byte[] from class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline |
From |
To |
|
Push Down Attribute private bytesAcked : long from class org.apache.hadoop.hdfs.server.datanode.ReplicaInPipeline to private bytesAcked : long from class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline |
From |
To |
|
Push Down Attribute private internedBaseDirs : Map<String,File> from class org.apache.hadoop.hdfs.server.datanode.ReplicaInfo to private internedBaseDirs : Map<String,File> from class org.apache.hadoop.hdfs.server.datanode.LocalReplica |
From |
To |
|
Push Down Attribute private bytesOnDisk : long from class org.apache.hadoop.hdfs.server.datanode.ReplicaInPipeline to private bytesOnDisk : long from class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline |
From |
To |
|
Merge Parameter [blockFile : File, metaFile : File] to replicaToDelete : ReplicaInfo in method package deleteAsync(volumeRef FsVolumeReference, replicaToDelete ReplicaInfo, block ExtendedBlock, trashDirectory String) : void in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetAsyncDiskService |
From |
To |
|
Merge Parameter [blockFile : File, metaFile : File] to replica : ReplicaInfo in method package submitLazyPersistTask(bpId String, blockId long, genStamp long, creationTime long, replica ReplicaInfo, target FsVolumeReference) : void in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.RamDiskAsyncLazyPersistService |
From |
To |
|
Merge Parameter [srcMeta : File, srcFile : File] to srcReplica : ReplicaInfo in method package copyBlockFiles(srcReplica ReplicaInfo, dstMeta File, dstFile File, calculateChecksum boolean, smallBufferSize int, conf Configuration) : File[] in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Merge Parameter [srcMeta : File, srcFile : File] to srcReplica : ReplicaInfo in method package copyBlockFiles(blockId long, genStamp long, srcReplica ReplicaInfo, destRoot File, calculateChecksum boolean, smallBufferSize int, conf Configuration) : File[] in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Merge Parameter [metaFile : File, blockFile : File] to replicaState : RamDiskReplica in method package activateSavedReplica(replicaInfo ReplicaInfo, replicaState RamDiskReplica) : ReplicaInfo in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.BlockPoolSlice |
From |
To |
|
Merge Parameter [blockFileUsed : long, metaFileUsed : long] to replicaInfo : ReplicaInfo in method private removeOldReplica(replicaInfo ReplicaInfo, newReplicaInfo ReplicaInfo, bpid String) : void in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Change Variable Type rbw : ReplicaBeingWritten to rbw : ReplicaInPipeline in method public convertTemporaryToRbw(b ExtendedBlock) : ReplicaInPipeline in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Change Variable Type rbw : ReplicaBeingWritten to rbw : ReplicaInPipeline in method public recoverRbw(b ExtendedBlock, newGS long, minBytesRcvd long, maxBytesRcvd long) : ReplicaHandler in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Change Variable Type rip : ReplicaInPipeline to rip : LocalReplicaInPipeline in method public createReplicaInPipeline(volume FsVolumeSpi, block ExtendedBlock) : Replica in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImplTestUtils |
From |
To |
|
Change Variable Type newReplicaInfo : FinalizedReplica to newReplicaInfo : ReplicaInfo in method private finalizeReplica(bpid String, replicaInfo ReplicaInfo) : ReplicaInfo in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Change Variable Type bInfo : ReplicaInPipelineInterface to bInfo : ReplicaInPipeline in method package addSomeBlocks(fsdataset SimulatedFSDataset, startingBlockId long, negativeBlkID boolean) : int in class org.apache.hadoop.hdfs.server.datanode.TestSimulatedFSDataset |
From |
To |
|
Change Variable Type inst : ReplicaInPipelineInterface to inst : ReplicaInPipeline in method public testInstantiateReplicaInPipeline() : void in class org.apache.hadoop.hdfs.server.datanode.extdataset.TestExternalDataset |
From |
To |
|
Change Variable Type memBlock : FinalizedReplica to memBlock : ReplicaInfo in method private scan() : void in class org.apache.hadoop.hdfs.server.datanode.DirectoryScanner |
From |
To |
|
Change Variable Type f : File to r : ReplicaInfo in method public setPinning(block ExtendedBlock) : void in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Change Variable Type replica : ReplicaBeingWritten to replica : ReplicaInPipeline in method public recoverAppend(b ExtendedBlock, newGS long, expectedBlockLen long) : ReplicaHandler in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Change Variable Type replica : FinalizedReplica to replica : ReplicaInfo in method private thistest(conf Configuration, util DFSTestUtil) : void in class org.apache.hadoop.hdfs.TestCrcCorruption |
From |
To |
|
Change Variable Type finalized : ArrayList<FinalizedReplica> to finalized : ArrayList<ReplicaInfo> in method public getFinalizedBlocksOnPersistentStorage(bpid String) : List<ReplicaInfo> in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Change Variable Type blockfile : File to r : ReplicaInfo in method public getStoredBlock(bpid String, blkid long) : Block in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Change Variable Type rbw : ReplicaBeingWritten to rbw : ReplicaInPipeline in method package BlockSender(block ExtendedBlock, startOffset long, length long, corruptChecksumOk boolean, verifyChecksum boolean, sendChecksum boolean, datanode DataNode, clientTraceFmt String, cachingStrategy CachingStrategy) in class org.apache.hadoop.hdfs.server.datanode.BlockSender |
From |
To |
|
Change Variable Type temp : ReplicaInPipeline to temp : ReplicaInfo in method public convertTemporaryToRbw(b ExtendedBlock) : ReplicaInPipeline in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Change Variable Type replicas : List<FinalizedReplica> to replicas : List<ReplicaInfo> in method private thistest(conf Configuration, util DFSTestUtil) : void in class org.apache.hadoop.hdfs.TestCrcCorruption |
From |
To |
|
Change Variable Type replicaInfo : ReplicaInPipelineInterface to replicaInfo : ReplicaInPipeline in method public testNotMatchedReplicaID() : void in class org.apache.hadoop.hdfs.server.datanode.TestBlockRecovery |
From |
To |
|
Change Variable Type f : File to r : ReplicaInfo in method package getBlockReplica(bpid String, blockId long) : ReplicaInfo in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Change Variable Type finalized : FinalizedReplica to finalized : ReplicaInfo in method public updateReplicaUnderRecovery(oldBlock ExtendedBlock, recoveryId long, newBlockId long, newlength long) : Replica in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Change Variable Type replicaInfo : ReplicaInPipelineInterface to replicaInfo : ReplicaInPipeline in method public testPipelineRecoveryWithTransferBlock() : void in class org.apache.hadoop.hdfs.TestClientProtocolForPipelineRecovery |
From |
To |
|
Change Variable Type f : File to r : ReplicaInfo in method package validateBlockFile(bpid String, blockId long) : ReplicaInfo in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Change Variable Type f : File to r : ReplicaInfo in method public getStoredDataLength(block ExtendedBlock) : long in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImplTestUtils |
From |
To |
|
Change Variable Type f : File to r : ReplicaInfo in method public getStoredGenerationStamp(block ExtendedBlock) : long in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImplTestUtils |
From |
To |
|
Change Variable Type rbw : ReplicaBeingWritten to rbw : ReplicaInPipeline in method private recoverCheck(b ExtendedBlock, newGS long, expectedBlockLen long) : ReplicaInfo in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Change Variable Type rur : ReplicaUnderRecovery to rur : ReplicaInfo in method package initReplicaRecoveryImpl(bpid String, map ReplicaMap, block Block, recoveryId long) : ReplicaRecoveryInfo in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Change Variable Type info : ReplicaInfo to info : LocalReplica in method public breakHardlinksIfNeeded(fsd FsDatasetSpi<?>, block ExtendedBlock) : boolean in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetTestUtil |
From |
To |
|
Change Variable Type volume : FsVolumeSpi to volume : FsVolumeImpl in method private updateReplicaUnderRecovery(bpid String, rur ReplicaInfo, recoveryId long, newBlockId long, newlength long) : ReplicaInfo in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Change Variable Type f : File to r : ReplicaInfo in method public getPinning(block ExtendedBlock) : boolean in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Change Variable Type meta : File to info : ReplicaInfo in method public getMetaDataInputStream(b ExtendedBlock) : LengthInputStream in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Change Variable Type bl : List<FinalizedReplica> to bl : List<ReplicaInfo> in method private scan() : void in class org.apache.hadoop.hdfs.server.datanode.DirectoryScanner |
From |
To |
|
Change Variable Type memReport : FinalizedReplica[] to memReport : ReplicaInfo[] in method private scan() : void in class org.apache.hadoop.hdfs.server.datanode.DirectoryScanner |
From |
To |
|
Change Variable Type current : FinalizedReplica to current : ReplicaInfo in method private scan() : void in class org.apache.hadoop.hdfs.server.datanode.DirectoryScanner |
From |
To |
|
Change Variable Type newReplicaInfo : ReplicaBeingWritten to newReplicaInfo : ReplicaInPipeline in method private updateReplicaUnderRecovery(bpid String, rur ReplicaInfo, recoveryId long, newBlockId long, newlength long) : ReplicaInfo in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Change Variable Type finalized : ArrayList<FinalizedReplica> to finalized : ArrayList<ReplicaInfo> in method public getFinalizedBlocks(bpid String) : List<ReplicaInfo> in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Change Variable Type info : ReplicaInfo to info : FinalizedReplica in method public createFinalizedReplica(volume FsVolumeSpi, block ExtendedBlock) : Replica in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImplTestUtils |
From |
To |
|
Change Variable Type replicaInfo : ReplicaInPipelineInterface to replicaInfo : ReplicaInPipeline in method private testWriteToTemporary(dataSet FsDatasetImpl, blocks ExtendedBlock[]) : void in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.TestWriteToReplica |
From |
To |
|
Change Variable Type replica : ReplicaBeingWritten to replica : ReplicaInPipeline in method public append(b ExtendedBlock, newGS long, expectedBlockLen long) : ReplicaHandler in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Push Down Method public stopWriter(xceiverStopTimeout long) : void from class org.apache.hadoop.hdfs.server.datanode.ReplicaInPipeline to public stopWriter(xceiverStopTimeout long) : void from class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline |
From |
To |
|
Push Down Method public getBytesOnDisk() : long from class org.apache.hadoop.hdfs.server.datanode.ReplicaInPipeline to public getBytesOnDisk() : long from class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline |
From |
To |
|
Push Down Method private setDirInternal(dir File) : void from class org.apache.hadoop.hdfs.server.datanode.ReplicaInfo to private setDirInternal(dir File) : void from class org.apache.hadoop.hdfs.server.datanode.LocalReplica |
From |
To |
|
Push Down Method public hashCode() : int from class org.apache.hadoop.hdfs.server.datanode.ReplicaInPipeline to public hashCode() : int from class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline |
From |
To |
|
Push Down Method package ReplicaInfo(from ReplicaInfo) from class org.apache.hadoop.hdfs.server.datanode.ReplicaInfo to package LocalReplica(from LocalReplica) from class org.apache.hadoop.hdfs.server.datanode.LocalReplica |
From |
To |
|
Push Down Method public getLastChecksumAndDataLen() : ChunkChecksum from class org.apache.hadoop.hdfs.server.datanode.ReplicaInPipeline to public getLastChecksumAndDataLen() : ChunkChecksum from class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline |
From |
To |
|
Push Down Method public setBytesAcked(bytesAcked long) : void from class org.apache.hadoop.hdfs.server.datanode.ReplicaInPipeline to public setBytesAcked(bytesAcked long) : void from class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline |
From |
To |
|
Push Down Method public parseBaseDir(dir File) : ReplicaDirInfo from class org.apache.hadoop.hdfs.server.datanode.ReplicaInfo to public parseBaseDir(dir File) : ReplicaDirInfo from class org.apache.hadoop.hdfs.server.datanode.LocalReplica |
From |
To |
|
Push Down Method package getDir() : File from class org.apache.hadoop.hdfs.server.datanode.ReplicaInfo to protected getDir() : File from class org.apache.hadoop.hdfs.server.datanode.LocalReplica |
From |
To |
|
Push Down Method public getBytesAcked() : long from class org.apache.hadoop.hdfs.server.datanode.ReplicaInPipeline to public getBytesAcked() : long from class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline |
From |
To |
|
Push Down Method public getVisibleLength() : long from class org.apache.hadoop.hdfs.server.datanode.ReplicaInPipeline to public getVisibleLength() : long from class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline |
From |
To |
|
Push Down Method public setLastChecksumAndDataLen(dataLength long, lastChecksum byte[]) : void from class org.apache.hadoop.hdfs.server.datanode.ReplicaInPipeline to public setLastChecksumAndDataLen(dataLength long, checksum byte[]) : void from class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline |
From |
To |
|
Push Down Method public getState() : ReplicaState from class org.apache.hadoop.hdfs.server.datanode.ReplicaInPipeline to public getState() : ReplicaState from class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline |
From |
To |
|
Push Down Method public getBytesReserved() : long from class org.apache.hadoop.hdfs.server.datanode.ReplicaInPipeline to public getBytesReserved() : long from class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline |
From |
To |
|
Push Down Method public releaseAllBytesReserved() : void from class org.apache.hadoop.hdfs.server.datanode.ReplicaInPipeline to public releaseAllBytesReserved() : void from class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline |
From |
To |
|
Push Down Method public attemptToSetWriter(prevWriter Thread, newWriter Thread) : boolean from class org.apache.hadoop.hdfs.server.datanode.ReplicaInPipeline to public attemptToSetWriter(prevWriter Thread, newWriter Thread) : boolean from class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline |
From |
To |
|
Push Down Method public breakHardLinksIfNeeded() : boolean from class org.apache.hadoop.hdfs.server.datanode.ReplicaInfo to public breakHardLinksIfNeeded() : boolean from class org.apache.hadoop.hdfs.server.datanode.LocalReplica |
From |
To |
|
Push Down Method public toString() : String from class org.apache.hadoop.hdfs.server.datanode.ReplicaInPipeline to public toString() : String from class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline |
From |
To |
|
Push Down Method public createRestartMetaStream() : OutputStream from class org.apache.hadoop.hdfs.server.datanode.ReplicaInPipeline to public createRestartMetaStream() : OutputStream from class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline |
From |
To |
|
Push Down Method public equals(o Object) : boolean from class org.apache.hadoop.hdfs.server.datanode.ReplicaInPipeline to public equals(o Object) : boolean from class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline |
From |
To |
|
Push Down Method public createStreams(isCreate boolean, requestedChecksum DataChecksum) : ReplicaOutputStreams from class org.apache.hadoop.hdfs.server.datanode.ReplicaInPipeline to public createStreams(isCreate boolean, requestedChecksum DataChecksum) : ReplicaOutputStreams from class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline |
From |
To |
|
Push Down Method public getBlockFile() : File from class org.apache.hadoop.hdfs.server.datanode.ReplicaInfo to public getBlockFile() : File from class org.apache.hadoop.hdfs.server.datanode.LocalReplica |
From |
To |
|
Push Down Method package ReplicaInfo(block Block, vol FsVolumeSpi, dir File) from class org.apache.hadoop.hdfs.server.datanode.ReplicaInfo to package LocalReplica(block Block, vol FsVolumeSpi, dir File) from class org.apache.hadoop.hdfs.server.datanode.LocalReplica |
From |
To |
|
Push Down Method private breakHardlinks(file File, b Block) : void from class org.apache.hadoop.hdfs.server.datanode.ReplicaInfo to private breakHardlinks(file File, b Block) : void from class org.apache.hadoop.hdfs.server.datanode.LocalReplica |
From |
To |
|
Push Down Method public getMetaFile() : File from class org.apache.hadoop.hdfs.server.datanode.ReplicaInfo to public getMetaFile() : File from class org.apache.hadoop.hdfs.server.datanode.LocalReplica |
From |
To |
|
Push Down Method public getOriginalBytesReserved() : long from class org.apache.hadoop.hdfs.server.datanode.ReplicaInPipeline to public getOriginalBytesReserved() : long from class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline |
From |
To |
|
Push Down Method public interruptThread() : void from class org.apache.hadoop.hdfs.server.datanode.ReplicaInPipeline to public interruptThread() : void from class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline |
From |
To |
|
Change Return Type ReplicaInPipelineInterface to ReplicaInPipeline in method public getReplica() : ReplicaInPipeline in class org.apache.hadoop.hdfs.server.datanode.ReplicaHandler |
From |
To |
|
Change Return Type List<FinalizedReplica> to List<ReplicaInfo> in method public getFinalizedBlocks(bpid String) : List<ReplicaInfo> in class org.apache.hadoop.hdfs.server.datanode.fsdataset.FsDatasetSpi |
From |
To |
|
Change Return Type ReplicaInPipeline to LocalReplicaInPipeline in method private getReplica(datanode DataNode, bpid String, expectedState ReplicaState) : LocalReplicaInPipeline in class org.apache.hadoop.hdfs.server.datanode.TestTransferRbw |
From |
To |
|
Change Return Type File to ReplicaInfo in method package getBlockReplica(bpid String, blockId long) : ReplicaInfo in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Change Return Type FinalizedReplica to ReplicaInfo in method private finalizeReplica(bpid String, replicaInfo ReplicaInfo) : ReplicaInfo in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Change Return Type List<FinalizedReplica> to List<ReplicaInfo> in method public getFinalizedBlocksOnPersistentStorage(bpid String) : List<ReplicaInfo> in class org.apache.hadoop.hdfs.server.datanode.SimulatedFSDataset |
From |
To |
|
Change Return Type List<FinalizedReplica> to List<ReplicaInfo> in method public getFinalizedBlocksOnPersistentStorage(bpid String) : List<ReplicaInfo> in class org.apache.hadoop.hdfs.server.datanode.fsdataset.FsDatasetSpi |
From |
To |
|
Change Return Type File to ReplicaInfo in method private getBlockReplica(b ExtendedBlock) : ReplicaInfo in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Change Return Type File to ReplicaInfo in method package activateSavedReplica(replicaInfo ReplicaInfo, replicaState RamDiskReplica) : ReplicaInfo in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.BlockPoolSlice |
From |
To |
|
Change Return Type FinalizedReplica to ReplicaInfo in method private updateReplicaUnderRecovery(bpid String, rur ReplicaInfo, recoveryId long, newBlockId long, newlength long) : ReplicaInfo in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Change Return Type File to ReplicaInfo in method private getBlockFile(eb ExtendedBlock) : ReplicaInfo in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImplTestUtils |
From |
To |
|
Change Return Type List<FinalizedReplica> to List<ReplicaInfo> in method public getFinalizedBlocksOnPersistentStorage(bpid String) : List<ReplicaInfo> in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Change Return Type ReplicaInPipelineInterface to ReplicaInPipeline in method public convertTemporaryToRbw(temporary ExtendedBlock) : ReplicaInPipeline in class org.apache.hadoop.hdfs.server.datanode.extdataset.ExternalDatasetImpl |
From |
To |
|
Change Return Type List<FinalizedReplica> to List<ReplicaInfo> in method public getFinalizedBlocks(bpid String) : List<ReplicaInfo> in class org.apache.hadoop.hdfs.server.datanode.SimulatedFSDataset |
From |
To |
|
Change Return Type List<FinalizedReplica> to List<ReplicaInfo> in method public getFinalizedBlocks(bpid String) : List<ReplicaInfo> in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Change Return Type List<FinalizedReplica> to List<ReplicaInfo> in method public getFinalizedBlocks(bpid String) : List<ReplicaInfo> in class org.apache.hadoop.hdfs.server.datanode.extdataset.ExternalDatasetImpl |
From |
To |
|
Change Return Type File to ReplicaInfo in method package validateBlockFile(bpid String, blockId long) : ReplicaInfo in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Change Return Type List<FinalizedReplica> to List<ReplicaInfo> in method public getFinalizedBlocksOnPersistentStorage(bpid String) : List<ReplicaInfo> in class org.apache.hadoop.hdfs.server.datanode.extdataset.ExternalDatasetImpl |
From |
To |
|
Change Return Type File to ReplicaInfo in method package addFinalizedBlock(bpid String, b Block, replicaInfo ReplicaInfo, bytesReserved long) : ReplicaInfo in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsVolumeImpl |
From |
To |
|
Change Return Type ReplicaInPipelineInterface to ReplicaInPipeline in method public convertTemporaryToRbw(temporary ExtendedBlock) : ReplicaInPipeline in class org.apache.hadoop.hdfs.server.datanode.SimulatedFSDataset |
From |
To |
|
Change Return Type ReplicaInPipelineInterface to ReplicaInPipeline in method public convertTemporaryToRbw(temporary ExtendedBlock) : ReplicaInPipeline in class org.apache.hadoop.hdfs.server.datanode.fsdataset.FsDatasetSpi |
From |
To |
|
Rename Parameter srcfile : File to replicaInfo : ReplicaInfo in method package moveBlockFiles(b Block, replicaInfo ReplicaInfo, destdir File) : File in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Rename Parameter blockFile : File to info : ReplicaInfo in method public getTrashDirectoryForReplica(bpid String, info ReplicaInfo) : String in class org.apache.hadoop.hdfs.server.datanode.DataStorage |
From |
To |
|
Rename Parameter lastChecksum : byte[] to checksum : byte[] in method public setLastChecksumAndDataLen(dataLength long, checksum byte[]) : void in class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline |
From |
To |
|
Rename Parameter f : File to replicaInfo : ReplicaInfo in method package addFinalizedBlock(bpid String, b Block, replicaInfo ReplicaInfo, bytesReserved long) : ReplicaInfo in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsVolumeImpl |
From |
To |
|
Rename Parameter conf : Configuration to c : Configuration in method package addBlockPool(bpid String, c Configuration, timer Timer) : void in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsVolumeImpl |
From |
To |
|
Rename Parameter blockFile : File to replicaToDelete : ReplicaInfo in method package ReplicaFileDeleteTask(volumeRef FsVolumeReference, replicaToDelete ReplicaInfo, block ExtendedBlock, trashDirectory String) in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetAsyncDiskService.ReplicaFileDeleteTask |
From |
To |
|
Rename Parameter conf : Configuration to c : Configuration in method package addBlockPool(bpid String, c Configuration) : void in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsVolumeImpl |
From |
To |
|
Rename Parameter f : File to replicaInfo : ReplicaInfo in method package addFinalizedBlock(b Block, replicaInfo ReplicaInfo) : File in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.BlockPoolSlice |
From |
To |
|
Rename Parameter blockFile : File to replicaInfo : ReplicaInfo in method package ReplicaLazyPersistTask(bpId String, blockId long, genStamp long, creationTime long, replicaInfo ReplicaInfo, targetVolume FsVolumeReference, lazyPersistDir File) in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.RamDiskAsyncLazyPersistService.ReplicaLazyPersistTask |
From |
To |