|
Rename Method public resultsCount() : int renamed to public getMovementFinishedBlocksCount() : int in class org.apache.hadoop.hdfs.server.namenode.BlockStorageMovementAttemptedItems |
From |
To |
|
Rename Method public getTargets() : DatanodeInfo[] renamed to public getTarget() : DatanodeInfo in class org.apache.hadoop.hdfs.server.protocol.BlockStorageMovementCommand.BlockMovingInfo |
From |
To |
|
Rename Method public testNoResultAdded() : void renamed to public testNoBlockMovementAttemptFinishedReportAdded() : void in class org.apache.hadoop.hdfs.server.namenode.TestBlockStorageMovementAttemptedItems |
From |
To |
|
Rename Method private waitForBlocksMovementResult(expectedBlkMovResultsCount long, timeout int) : void renamed to private waitForBlocksMovementAttemptReport(expectedMovementFinishedBlocksCount long, timeout int) : void in class org.apache.hadoop.hdfs.server.namenode.TestStoragePolicySatisfier |
From |
To |
|
Rename Method public getSources() : DatanodeInfo[] renamed to public getSource() : DatanodeInfo in class org.apache.hadoop.hdfs.server.protocol.BlockStorageMovementCommand.BlockMovingInfo |
From |
To |
|
Rename Method public getTargetStorageTypes() : StorageType[] renamed to public getTargetStorageType() : StorageType in class org.apache.hadoop.hdfs.server.protocol.BlockStorageMovementCommand.BlockMovingInfo |
From |
To |
|
Rename Method public getSourceStorageTypes() : StorageType[] renamed to public getSourceStorageType() : StorageType in class org.apache.hadoop.hdfs.server.protocol.BlockStorageMovementCommand.BlockMovingInfo |
From |
To |
|
Rename Method private addMovementResultToTrackIdList(result BlockMovementResult) : List<BlockMovementResult> renamed to private addMovementResultToBlockIdList(result BlockMovementAttemptFinished) : List<BlockMovementAttemptFinished> in class org.apache.hadoop.hdfs.server.datanode.BlockStorageMovementTracker |
From |
To |
|
Rename Method package getBlksMovementResults() : List<BlocksStorageMovementResult> renamed to package getMoveAttemptFinishedBlocks() : List<Block> in class org.apache.hadoop.hdfs.server.datanode.StoragePolicySatisfyWorker.BlocksMovementsStatusHandler |
From |
To |
|
Rename Method private waitForBlocksMovementResult(cluster MiniDFSCluster, expectedBlkMovResultsCount long, timeout int) : void renamed to private waitForBlocksMovementAttemptReport(cluster MiniDFSCluster, expectedMovementFinishedBlocksCount long, timeout int) : void in class org.apache.hadoop.hdfs.server.namenode.TestStoragePolicySatisfierWithStripedFile |
From |
To |
|
Rename Method public testPerTrackIdBlocksStorageMovementResults() : void renamed to public testBlksStorageMovementAttemptFinishedReport() : void in class org.apache.hadoop.hdfs.server.namenode.TestStoragePolicySatisfier |
From |
To |
|
Change Parameter Type moverCompletionService : CompletionService<BlockMovementResult> to moverCompletionService : CompletionService<BlockMovementAttemptFinished> in method public BlockStorageMovementTracker(moverCompletionService CompletionService<BlockMovementAttemptFinished>, handler BlocksMovementsStatusHandler) in class org.apache.hadoop.hdfs.server.datanode.BlockStorageMovementTracker |
From |
To |
|
Change Parameter Type blksMovementResults : BlocksStorageMovementResult[] to storageMovementFinishedBlks : BlocksStorageMoveAttemptFinished in method public sendHeartbeat(registration DatanodeRegistration, reports StorageReport[], cacheCapacity long, cacheUsed long, xmitsInProgress int, xceiverCount int, failedVolumes int, volumeFailureSummary VolumeFailureSummary, requestFullBlockReportLease boolean, slowPeers SlowPeerReports, slowDisks SlowDiskReports, storageMovementFinishedBlks BlocksStorageMoveAttemptFinished) : HeartbeatResponse in class org.apache.hadoop.hdfs.protocolPB.DatanodeProtocolClientSideTranslatorPB |
From |
To |
|
Change Parameter Type blkMovementStatus : BlocksStorageMovementResult[] to storageMovementFinishedBlks : BlocksStorageMoveAttemptFinished in method public sendHeartbeat(nodeReg DatanodeRegistration, report StorageReport[], dnCacheCapacity long, dnCacheUsed long, xmitsInProgress int, xceiverCount int, failedVolumes int, volumeFailureSummary VolumeFailureSummary, requestFullBlockReportLease boolean, slowPeers SlowPeerReports, slowDisks SlowDiskReports, storageMovementFinishedBlks BlocksStorageMoveAttemptFinished) : HeartbeatResponse in class org.apache.hadoop.hdfs.server.namenode.NameNodeRpcServer |
From |
To |
|
Change Parameter Type blockId : long to src : DatanodeInfo in method package BlockMovementAttemptFinished(block Block, src DatanodeInfo, target DatanodeInfo, status BlockMovementStatus) in class org.apache.hadoop.hdfs.server.datanode.StoragePolicySatisfyWorker.BlockMovementAttemptFinished |
From |
To |
|
Change Parameter Type trackID : long to block : Block in method package addBlock(block Block, futureTask Future<BlockMovementAttemptFinished>) : void in class org.apache.hadoop.hdfs.server.datanode.BlockStorageMovementTracker |
From |
To |
|
Change Parameter Type blockStoragePolicySatisfyProto : BlockStorageMovementProto to blockStorageMovingInfoProto : BlockMovingInfoProto in method private convertBlockMovingInfo(blockStorageMovingInfoProto BlockMovingInfoProto) : BlockMovingInfo in class org.apache.hadoop.hdfs.protocolPB.PBHelper |
From |
To |
|
Change Parameter Type srcStorageTypes : StorageType[] to srcStorageType : StorageType in method public BlockMovingInfo(block Block, sourceDnInfo DatanodeInfo, targetDnInfo DatanodeInfo, srcStorageType StorageType, targetStorageType StorageType) in class org.apache.hadoop.hdfs.server.protocol.BlockStorageMovementCommand.BlockMovingInfo |
From |
To |
|
Change Parameter Type trackId : long to block : Block in method package BlockMovementAttemptFinished(block Block, src DatanodeInfo, target DatanodeInfo, status BlockMovementStatus) in class org.apache.hadoop.hdfs.server.datanode.StoragePolicySatisfyWorker.BlockMovementAttemptFinished |
From |
To |
|
Change Parameter Type targetStorageTypes : StorageType[] to targetStorageType : StorageType in method public BlockMovingInfo(block Block, sourceDnInfo DatanodeInfo, targetDnInfo DatanodeInfo, srcStorageType StorageType, targetStorageType StorageType) in class org.apache.hadoop.hdfs.server.protocol.BlockStorageMovementCommand.BlockMovingInfo |
From |
To |
|
Change Parameter Type targetDnInfos : DatanodeInfo[] to targetDnInfo : DatanodeInfo in method public BlockMovingInfo(block Block, sourceDnInfo DatanodeInfo, targetDnInfo DatanodeInfo, srcStorageType StorageType, targetStorageType StorageType) in class org.apache.hadoop.hdfs.server.protocol.BlockStorageMovementCommand.BlockMovingInfo |
From |
To |
|
Change Parameter Type sourceDnInfos : DatanodeInfo[] to sourceDnInfo : DatanodeInfo in method public BlockMovingInfo(block Block, sourceDnInfo DatanodeInfo, targetDnInfo DatanodeInfo, srcStorageType StorageType, targetStorageType StorageType) in class org.apache.hadoop.hdfs.server.protocol.BlockStorageMovementCommand.BlockMovingInfo |
From |
To |
|
Change Parameter Type result : BlockMovementResult to result : BlockMovementAttemptFinished in method private addMovementResultToBlockIdList(result BlockMovementAttemptFinished) : List<BlockMovementAttemptFinished> in class org.apache.hadoop.hdfs.server.datanode.BlockStorageMovementTracker |
From |
To |
|
Change Parameter Type blksMovementResults : BlocksStorageMovementResult[] to storageMovFinishedBlks : BlocksStorageMoveAttemptFinished in method public sendHeartbeat(registration DatanodeRegistration, reports StorageReport[], dnCacheCapacity long, dnCacheUsed long, xmitsInProgress int, xceiverCount int, failedVolumes int, volumeFailureSummary VolumeFailureSummary, requestFullBlockReportLease boolean, slowPeers SlowPeerReports, slowDisks SlowDiskReports, storageMovFinishedBlks BlocksStorageMoveAttemptFinished) : HeartbeatResponse in class org.apache.hadoop.hdfs.server.protocol.DatanodeProtocol |
From |
To |
|
Change Parameter Type blksMovementResults : BlocksStorageMovementResult[] to blksMovementsFinished : BlocksStorageMoveAttemptFinished in method package handleHeartbeat(nodeReg DatanodeRegistration, reports StorageReport[], cacheCapacity long, cacheUsed long, xceiverCount int, xmitsInProgress int, failedVolumes int, volumeFailureSummary VolumeFailureSummary, requestFullBlockReportLease boolean, slowPeers SlowPeerReports, slowDisks SlowDiskReports, blksMovementsFinished BlocksStorageMoveAttemptFinished) : HeartbeatResponse in class org.apache.hadoop.hdfs.server.namenode.FSNamesystem |
From |
To |
|
Change Parameter Type futureTask : Future<BlockMovementResult> to futureTask : Future<BlockMovementAttemptFinished> in method package addBlock(block Block, futureTask Future<BlockMovementAttemptFinished>) : void in class org.apache.hadoop.hdfs.server.datanode.BlockStorageMovementTracker |
From |
To |
|
Rename Variable sourceDnInfos : DatanodeInfo[] to sourceDnInfo : DatanodeInfo in method private convertBlockMovingInfo(blockStorageMovingInfoProto BlockMovingInfoProto) : BlockMovingInfo in class org.apache.hadoop.hdfs.protocolPB.PBHelper |
From |
To |
|
Rename Variable storageMovementAttemptedResult : BlocksStorageMovementResult to itemInfo : AttemptedItemInfo in method package blocksStorageMovementUnReportedItemsCheck() : void in class org.apache.hadoop.hdfs.server.namenode.BlockStorageMovementAttemptedItems |
From |
To |
|
Rename Variable perTrackIdList : List<BlockMovementResult> to perBlockIdList : List<BlockMovementAttemptFinished> in method private addMovementResultToBlockIdList(result BlockMovementAttemptFinished) : List<BlockMovementAttemptFinished> in class org.apache.hadoop.hdfs.server.datanode.BlockStorageMovementTracker |
From |
To |
|
Rename Variable targetDnInfos : DatanodeInfo[] to targetDnInfo : DatanodeInfo in method private convertBlockMovingInfo(blkMovingInfo BlockMovingInfo) : BlockMovingInfoProto in class org.apache.hadoop.hdfs.protocolPB.PBHelper |
From |
To |
|
Rename Variable targetStorageTypes : StorageType[] to targetStorageType : StorageType in method private convertBlockMovingInfo(blkMovingInfo BlockMovingInfo) : BlockMovingInfoProto in class org.apache.hadoop.hdfs.protocolPB.PBHelper |
From |
To |
|
Rename Variable trackId : long to block : Block in method private addMovementResultToBlockIdList(result BlockMovementAttemptFinished) : List<BlockMovementAttemptFinished> in class org.apache.hadoop.hdfs.server.datanode.BlockStorageMovementTracker |
From |
To |
|
Rename Variable computeStatus : boolean to blocksPaired : boolean in method private analyseBlocksStorageMovementsAndAssignToDN(blockCollection BlockCollection) : BlocksMovingAnalysis in class org.apache.hadoop.hdfs.server.namenode.StoragePolicySatisfier |
From |
To |
|
Rename Variable sourceDnInfos : DatanodeInfo[] to sourceDnInfo : DatanodeInfo in method private convertBlockMovingInfo(blkMovingInfo BlockMovingInfo) : BlockMovingInfoProto in class org.apache.hadoop.hdfs.protocolPB.PBHelper |
From |
To |
|
Rename Variable sourceStorageTypes : StorageType[] to sourceStorageType : StorageType in method private convertBlockMovingInfo(blkMovingInfo BlockMovingInfo) : BlockMovingInfoProto in class org.apache.hadoop.hdfs.protocolPB.PBHelper |
From |
To |
|
Rename Variable blkStorageMovementInfosBatch : BlockStorageMovementInfosBatch to blkStorageMovementInfos : BlockMovingInfo[] in method public handleHeartbeat(nodeReg DatanodeRegistration, reports StorageReport[], blockPoolId String, cacheCapacity long, cacheUsed long, xceiverCount int, maxTransfers int, failedVolumes int, volumeFailureSummary VolumeFailureSummary, slowPeers SlowPeerReports, slowDisks SlowDiskReports) : DatanodeCommand[] in class org.apache.hadoop.hdfs.server.blockmanagement.DatanodeManager |
From |
To |
|
Rename Variable movementResults : List<BlocksStorageMovementResult> to moveAttemptFinishedBlks : List<Block> in method package getMoveAttemptFinishedBlocks() : List<Block> in class org.apache.hadoop.hdfs.server.datanode.StoragePolicySatisfyWorker.BlocksMovementsStatusHandler |
From |
To |
|
Rename Variable targetStorageTypes : StorageType[] to targetStorageType : StorageType in method private convertBlockMovingInfo(blockStorageMovingInfoProto BlockMovingInfoProto) : BlockMovingInfo in class org.apache.hadoop.hdfs.protocolPB.PBHelper |
From |
To |
|
Rename Variable targetDnInfos : DatanodeInfo[] to targetDnInfo : DatanodeInfo in method private convertBlockMovingInfo(blockStorageMovingInfoProto BlockMovingInfoProto) : BlockMovingInfo in class org.apache.hadoop.hdfs.protocolPB.PBHelper |
From |
To |
|
Rename Variable trackId : long to block : Block in method public run() : void in class org.apache.hadoop.hdfs.server.datanode.BlockStorageMovementTracker |
From |
To |
|
Rename Variable srcStorageTypes : StorageType[] to srcStorageType : StorageType in method private convertBlockMovingInfo(blockStorageMovingInfoProto BlockMovingInfoProto) : BlockMovingInfo in class org.apache.hadoop.hdfs.protocolPB.PBHelper |
From |
To |
|
Change Return Type StorageType[] to StorageType in method public getSourceStorageType() : StorageType in class org.apache.hadoop.hdfs.server.protocol.BlockStorageMovementCommand.BlockMovingInfo |
From |
To |
|
Change Return Type List<BlocksStorageMovementResult> to List<Block> in method package getMoveAttemptFinishedBlocks() : List<Block> in class org.apache.hadoop.hdfs.server.datanode.StoragePolicySatisfyWorker.BlocksMovementsStatusHandler |
From |
To |
|
Change Return Type BlockStorageMovementProto to BlockMovingInfoProto in method private convertBlockMovingInfo(blkMovingInfo BlockMovingInfo) : BlockMovingInfoProto in class org.apache.hadoop.hdfs.protocolPB.PBHelper |
From |
To |
|
Change Return Type DatanodeInfo[] to DatanodeInfo in method public getSource() : DatanodeInfo in class org.apache.hadoop.hdfs.server.protocol.BlockStorageMovementCommand.BlockMovingInfo |
From |
To |
|
Change Return Type BlockMovementResult to BlockMovementAttemptFinished in method public call() : BlockMovementAttemptFinished in class org.apache.hadoop.hdfs.server.datanode.StoragePolicySatisfyWorker.BlockMovingTask |
From |
To |
|
Change Return Type List<BlockMovementResult> to List<BlockMovementAttemptFinished> in method private addMovementResultToBlockIdList(result BlockMovementAttemptFinished) : List<BlockMovementAttemptFinished> in class org.apache.hadoop.hdfs.server.datanode.BlockStorageMovementTracker |
From |
To |
|
Change Return Type BlocksMovingAnalysisStatus to BlocksMovingAnalysis in method private analyseBlocksStorageMovementsAndAssignToDN(blockCollection BlockCollection) : BlocksMovingAnalysis in class org.apache.hadoop.hdfs.server.namenode.StoragePolicySatisfier |
From |
To |
|
Change Return Type long to Block in method package getBlock() : Block in class org.apache.hadoop.hdfs.server.datanode.StoragePolicySatisfyWorker.BlockMovementAttemptFinished |
From |
To |
|
Change Return Type StorageType[] to StorageType in method public getTargetStorageType() : StorageType in class org.apache.hadoop.hdfs.server.protocol.BlockStorageMovementCommand.BlockMovingInfo |
From |
To |
|
Change Return Type DatanodeInfo[] to DatanodeInfo in method public getTarget() : DatanodeInfo in class org.apache.hadoop.hdfs.server.protocol.BlockStorageMovementCommand.BlockMovingInfo |
From |
To |
|
Change Variable Type future : Future<BlockMovementResult> to future : Future<BlockMovementAttemptFinished> in method public run() : void in class org.apache.hadoop.hdfs.server.datanode.BlockStorageMovementTracker |
From |
To |
|
Change Variable Type status : BlocksMovingAnalysisStatus to status : BlocksMovingAnalysis.Status in method private analyseBlocksStorageMovementsAndAssignToDN(blockCollection BlockCollection) : BlocksMovingAnalysis in class org.apache.hadoop.hdfs.server.namenode.StoragePolicySatisfier |
From |
To |
|
Change Variable Type sourceStorageTypes : StorageType[] to sourceStorageType : StorageType in method private convertBlockMovingInfo(blkMovingInfo BlockMovingInfo) : BlockMovingInfoProto in class org.apache.hadoop.hdfs.protocolPB.PBHelper |
From |
To |
|
Change Variable Type movementResults : List<BlocksStorageMovementResult> to moveAttemptFinishedBlks : List<Block> in method package getMoveAttemptFinishedBlocks() : List<Block> in class org.apache.hadoop.hdfs.server.datanode.StoragePolicySatisfyWorker.BlocksMovementsStatusHandler |
From |
To |
|
Change Variable Type trackId : long to block : Block in method public run() : void in class org.apache.hadoop.hdfs.server.datanode.BlockStorageMovementTracker |
From |
To |
|
Change Variable Type futures : List<Future<BlockMovementResult>> to futures : List<Future<BlockMovementAttemptFinished>> in method package addBlock(block Block, futureTask Future<BlockMovementAttemptFinished>) : void in class org.apache.hadoop.hdfs.server.datanode.BlockStorageMovementTracker |
From |
To |
|
Change Variable Type sourceDnInfos : DatanodeInfo[] to sourceDnInfo : DatanodeInfo in method private convertBlockMovingInfo(blockStorageMovingInfoProto BlockMovingInfoProto) : BlockMovingInfo in class org.apache.hadoop.hdfs.protocolPB.PBHelper |
From |
To |
|
Change Variable Type blocksMoving : List<Future<BlockMovementResult>> to blocksMoving : List<Future<BlockMovementAttemptFinished>> in method public run() : void in class org.apache.hadoop.hdfs.server.datanode.BlockStorageMovementTracker |
From |
To |
|
Change Variable Type status : BlocksMovingAnalysisStatus to status : BlocksMovingAnalysis in method public run() : void in class org.apache.hadoop.hdfs.server.namenode.StoragePolicySatisfier |
From |
To |
|
Change Variable Type iter : Iterator<BlocksStorageMovementResult> to iter : Iterator<AttemptedItemInfo> in method package blocksStorageMovementUnReportedItemsCheck() : void in class org.apache.hadoop.hdfs.server.namenode.BlockStorageMovementAttemptedItems |
From |
To |
|
Change Variable Type result : BlockMovementResult to result : BlockMovementAttemptFinished in method public run() : void in class org.apache.hadoop.hdfs.server.datanode.BlockStorageMovementTracker |
From |
To |
|
Change Variable Type blkSPSatisfy : BlockStorageMovementProto to blkSPSatisfy : BlockMovingInfoProto in method private convert(blkStorageMovementCmdProto BlockStorageMovementCommandProto) : DatanodeCommand in class org.apache.hadoop.hdfs.protocolPB.PBHelper |
From |
To |
|
Change Variable Type moveCallable : Future<BlockMovementResult> to moveCallable : Future<BlockMovementAttemptFinished> in method public processBlockMovingTasks(blockPoolID String, blockMovingInfos Collection<BlockMovingInfo>) : void in class org.apache.hadoop.hdfs.server.datanode.StoragePolicySatisfyWorker |
From |
To |
|
Change Variable Type iter : Iterator<Entry<Long,AttemptedItemInfo>> to iter : Iterator<AttemptedItemInfo> in method package blocksStorageMovementUnReportedItemsCheck() : void in class org.apache.hadoop.hdfs.server.namenode.BlockStorageMovementAttemptedItems |
From |
To |
|
Change Variable Type perTrackIdList : List<BlockMovementResult> to perBlockIdList : List<BlockMovementAttemptFinished> in method private addMovementResultToBlockIdList(result BlockMovementAttemptFinished) : List<BlockMovementAttemptFinished> in class org.apache.hadoop.hdfs.server.datanode.BlockStorageMovementTracker |
From |
To |
|
Change Variable Type targetStorageTypes : StorageType[] to targetStorageType : StorageType in method private convertBlockMovingInfo(blkMovingInfo BlockMovingInfo) : BlockMovingInfoProto in class org.apache.hadoop.hdfs.protocolPB.PBHelper |
From |
To |
|
Change Variable Type targetDnInfos : DatanodeInfo[] to targetDnInfo : DatanodeInfo in method private convertBlockMovingInfo(blkMovingInfo BlockMovingInfo) : BlockMovingInfoProto in class org.apache.hadoop.hdfs.protocolPB.PBHelper |
From |
To |
|
Change Variable Type completedBlocks : List<BlocksStorageMovementResult> to completedBlocks : List<Block> in method public get() : Boolean in class org.apache.hadoop.hdfs.server.datanode.TestStoragePolicySatisfyWorker.waitForBlockMovementResult.waitFor |
From |
To |
|
Change Variable Type trackId : long to block : Block in method private addMovementResultToBlockIdList(result BlockMovementAttemptFinished) : List<BlockMovementAttemptFinished> in class org.apache.hadoop.hdfs.server.datanode.BlockStorageMovementTracker |
From |
To |
|
Change Variable Type sourceDnInfos : DatanodeInfo[] to sourceDnInfo : DatanodeInfo in method private convertBlockMovingInfo(blkMovingInfo BlockMovingInfo) : BlockMovingInfoProto in class org.apache.hadoop.hdfs.protocolPB.PBHelper |
From |
To |
|
Change Variable Type blkStorageMovementInfosBatch : BlockStorageMovementInfosBatch to blkStorageMovementInfos : BlockMovingInfo[] in method public handleHeartbeat(nodeReg DatanodeRegistration, reports StorageReport[], blockPoolId String, cacheCapacity long, cacheUsed long, xceiverCount int, maxTransfers int, failedVolumes int, volumeFailureSummary VolumeFailureSummary, slowPeers SlowPeerReports, slowDisks SlowDiskReports) : DatanodeCommand[] in class org.apache.hadoop.hdfs.server.blockmanagement.DatanodeManager |
From |
To |
|
Change Variable Type resultPerTrackIdList : List<BlockMovementResult> to resultPerTrackIdList : List<BlockMovementAttemptFinished> in method public run() : void in class org.apache.hadoop.hdfs.server.datanode.BlockStorageMovementTracker |
From |
To |
|
Change Variable Type targetDnInfos : DatanodeInfo[] to targetDnInfo : DatanodeInfo in method private convertBlockMovingInfo(blockStorageMovingInfoProto BlockMovingInfoProto) : BlockMovingInfo in class org.apache.hadoop.hdfs.protocolPB.PBHelper |
From |
To |
|
Change Variable Type targetStorageTypes : StorageType[] to targetStorageType : StorageType in method private convertBlockMovingInfo(blockStorageMovingInfoProto BlockMovingInfoProto) : BlockMovingInfo in class org.apache.hadoop.hdfs.protocolPB.PBHelper |
From |
To |
|
Change Variable Type srcStorageTypes : StorageType[] to srcStorageType : StorageType in method private convertBlockMovingInfo(blockStorageMovingInfoProto BlockMovingInfoProto) : BlockMovingInfo in class org.apache.hadoop.hdfs.protocolPB.PBHelper |
From |
To |
|
Change Variable Type blkSPSatisfyList : List<BlockStorageMovementProto> to blkSPSatisfyList : List<BlockMovingInfoProto> in method private convert(blkStorageMovementCmdProto BlockStorageMovementCommandProto) : DatanodeCommand in class org.apache.hadoop.hdfs.protocolPB.PBHelper |
From |
To |
|
Change Variable Type storageMovementAttemptedResult : BlocksStorageMovementResult to itemInfo : AttemptedItemInfo in method package blocksStorageMovementUnReportedItemsCheck() : void in class org.apache.hadoop.hdfs.server.namenode.BlockStorageMovementAttemptedItems |
From |
To |
|
Change Attribute Type targetStorageTypes : StorageType[] to targetStorageType : StorageType in class org.apache.hadoop.hdfs.server.protocol.BlockStorageMovementCommand.BlockMovingInfo |
From |
To |
|
Change Attribute Type trackId : long to block : Block in class org.apache.hadoop.hdfs.server.datanode.StoragePolicySatisfyWorker.BlockMovementAttemptFinished |
From |
To |
|
Change Attribute Type moverCompletionService : CompletionService<BlockMovementResult> to moverCompletionService : CompletionService<BlockMovementAttemptFinished> in class org.apache.hadoop.hdfs.server.datanode.BlockStorageMovementTracker |
From |
To |
|
Change Attribute Type storageMovementBlocks : Queue<BlockStorageMovementInfosBatch> to storageMovementBlocks : Queue<BlockMovingInfo> in class org.apache.hadoop.hdfs.server.blockmanagement.DatanodeDescriptor |
From |
To |
|
Change Attribute Type moverTaskFutures : Map<Long,List<Future<BlockMovementResult>>> to moverTaskFutures : Map<Block,List<Future<BlockMovementAttemptFinished>>> in class org.apache.hadoop.hdfs.server.datanode.BlockStorageMovementTracker |
From |
To |
|
Change Attribute Type targetNodes : DatanodeInfo[] to targetNode : DatanodeInfo in class org.apache.hadoop.hdfs.server.protocol.BlockStorageMovementCommand.BlockMovingInfo |
From |
To |
|
Change Attribute Type blockId : long to src : DatanodeInfo in class org.apache.hadoop.hdfs.server.datanode.StoragePolicySatisfyWorker.BlockMovementAttemptFinished |
From |
To |
|
Change Attribute Type moverCompletionService : CompletionService<BlockMovementResult> to moverCompletionService : CompletionService<BlockMovementAttemptFinished> in class org.apache.hadoop.hdfs.server.datanode.StoragePolicySatisfyWorker |
From |
To |
|
Change Attribute Type sourceNodes : DatanodeInfo[] to sourceNode : DatanodeInfo in class org.apache.hadoop.hdfs.server.protocol.BlockStorageMovementCommand.BlockMovingInfo |
From |
To |
|
Change Attribute Type sourceStorageTypes : StorageType[] to sourceStorageType : StorageType in class org.apache.hadoop.hdfs.server.protocol.BlockStorageMovementCommand.BlockMovingInfo |
From |
To |
|
Change Attribute Type movementResults : Map<Long,List<BlockMovementResult>> to movementResults : Map<Block,List<BlockMovementAttemptFinished>> in class org.apache.hadoop.hdfs.server.datanode.BlockStorageMovementTracker |
From |
To |
|
Change Attribute Type trackIdVsMovementStatus : List<BlocksStorageMovementResult> to blockIdVsMovementStatus : List<Block> in class org.apache.hadoop.hdfs.server.datanode.StoragePolicySatisfyWorker.BlocksMovementsStatusHandler |
From |
To |
|
Change Attribute Type storageMovementAttemptedItems : Map<Long,AttemptedItemInfo> to storageMovementAttemptedItems : List<AttemptedItemInfo> in class org.apache.hadoop.hdfs.server.namenode.BlockStorageMovementAttemptedItems |
From |
To |
|
Rename Parameter blkMovementStatus : BlocksStorageMovementResult[] to storageMovementFinishedBlks : BlocksStorageMoveAttemptFinished in method public sendHeartbeat(nodeReg DatanodeRegistration, report StorageReport[], dnCacheCapacity long, dnCacheUsed long, xmitsInProgress int, xceiverCount int, failedVolumes int, volumeFailureSummary VolumeFailureSummary, requestFullBlockReportLease boolean, slowPeers SlowPeerReports, slowDisks SlowDiskReports, storageMovementFinishedBlks BlocksStorageMoveAttemptFinished) : HeartbeatResponse in class org.apache.hadoop.hdfs.server.namenode.NameNodeRpcServer |
From |
To |
|
Rename Parameter blksMovementResults : BlocksStorageMovementResult[] to storageMovFinishedBlks : BlocksStorageMoveAttemptFinished in method public sendHeartbeat(registration DatanodeRegistration, reports StorageReport[], dnCacheCapacity long, dnCacheUsed long, xmitsInProgress int, xceiverCount int, failedVolumes int, volumeFailureSummary VolumeFailureSummary, requestFullBlockReportLease boolean, slowPeers SlowPeerReports, slowDisks SlowDiskReports, storageMovFinishedBlks BlocksStorageMoveAttemptFinished) : HeartbeatResponse in class org.apache.hadoop.hdfs.server.protocol.DatanodeProtocol |
From |
To |
|
Rename Parameter srcStorageTypes : StorageType[] to srcStorageType : StorageType in method public BlockMovingInfo(block Block, sourceDnInfo DatanodeInfo, targetDnInfo DatanodeInfo, srcStorageType StorageType, targetStorageType StorageType) in class org.apache.hadoop.hdfs.server.protocol.BlockStorageMovementCommand.BlockMovingInfo |
From |
To |
|
Rename Parameter expectedBlkMovResultsCount : long to expectedMovementFinishedBlocksCount : long in method private waitForBlocksMovementAttemptReport(cluster MiniDFSCluster, expectedMovementFinishedBlocksCount long, timeout int) : void in class org.apache.hadoop.hdfs.server.namenode.TestStoragePolicySatisfierWithStripedFile |
From |
To |
|
Rename Parameter blksMovementResults : BlocksStorageMovementResult[] to blksMovementsFinished : BlocksStorageMoveAttemptFinished in method package handleHeartbeat(nodeReg DatanodeRegistration, reports StorageReport[], cacheCapacity long, cacheUsed long, xceiverCount int, xmitsInProgress int, failedVolumes int, volumeFailureSummary VolumeFailureSummary, requestFullBlockReportLease boolean, slowPeers SlowPeerReports, slowDisks SlowDiskReports, blksMovementsFinished BlocksStorageMoveAttemptFinished) : HeartbeatResponse in class org.apache.hadoop.hdfs.server.namenode.FSNamesystem |
From |
To |
|
Rename Parameter targetStorageTypes : StorageType[] to targetStorageType : StorageType in method public BlockMovingInfo(block Block, sourceDnInfo DatanodeInfo, targetDnInfo DatanodeInfo, srcStorageType StorageType, targetStorageType StorageType) in class org.apache.hadoop.hdfs.server.protocol.BlockStorageMovementCommand.BlockMovingInfo |
From |
To |
|
Rename Parameter trackId : long to block : Block in method package BlockMovementAttemptFinished(block Block, src DatanodeInfo, target DatanodeInfo, status BlockMovementStatus) in class org.apache.hadoop.hdfs.server.datanode.StoragePolicySatisfyWorker.BlockMovementAttemptFinished |
From |
To |
|
Rename Parameter targetDnInfos : DatanodeInfo[] to targetDnInfo : DatanodeInfo in method public BlockMovingInfo(block Block, sourceDnInfo DatanodeInfo, targetDnInfo DatanodeInfo, srcStorageType StorageType, targetStorageType StorageType) in class org.apache.hadoop.hdfs.server.protocol.BlockStorageMovementCommand.BlockMovingInfo |
From |
To |
|
Rename Parameter blockId : long to src : DatanodeInfo in method package BlockMovementAttemptFinished(block Block, src DatanodeInfo, target DatanodeInfo, status BlockMovementStatus) in class org.apache.hadoop.hdfs.server.datanode.StoragePolicySatisfyWorker.BlockMovementAttemptFinished |
From |
To |
|
Rename Parameter sourceDnInfos : DatanodeInfo[] to sourceDnInfo : DatanodeInfo in method public BlockMovingInfo(block Block, sourceDnInfo DatanodeInfo, targetDnInfo DatanodeInfo, srcStorageType StorageType, targetStorageType StorageType) in class org.apache.hadoop.hdfs.server.protocol.BlockStorageMovementCommand.BlockMovingInfo |
From |
To |
|
Rename Parameter trackID : long to block : Block in method package addBlock(block Block, futureTask Future<BlockMovementAttemptFinished>) : void in class org.apache.hadoop.hdfs.server.datanode.BlockStorageMovementTracker |
From |
To |
|
Rename Parameter blockStoragePolicySatisfyProto : BlockStorageMovementProto to blockStorageMovingInfoProto : BlockMovingInfoProto in method private convertBlockMovingInfo(blockStorageMovingInfoProto BlockMovingInfoProto) : BlockMovingInfo in class org.apache.hadoop.hdfs.protocolPB.PBHelper |
From |
To |
|
Rename Parameter expectedBlkMovResultsCount : long to expectedMovementFinishedBlocksCount : long in method private waitForBlocksMovementAttemptReport(expectedMovementFinishedBlocksCount long, timeout int) : void in class org.apache.hadoop.hdfs.server.namenode.TestStoragePolicySatisfier |
From |
To |
|
Rename Parameter blksMovementResults : BlocksStorageMovementResult[] to storageMovementFinishedBlks : BlocksStorageMoveAttemptFinished in method public sendHeartbeat(registration DatanodeRegistration, reports StorageReport[], cacheCapacity long, cacheUsed long, xmitsInProgress int, xceiverCount int, failedVolumes int, volumeFailureSummary VolumeFailureSummary, requestFullBlockReportLease boolean, slowPeers SlowPeerReports, slowDisks SlowDiskReports, storageMovementFinishedBlks BlocksStorageMoveAttemptFinished) : HeartbeatResponse in class org.apache.hadoop.hdfs.protocolPB.DatanodeProtocolClientSideTranslatorPB |
From |
To |