|
Change Parameter Type fd : FileDescriptor to outs : ReplicaOutputStreams in method public submitBackgroundSyncFileRangeRequest(block ExtendedBlock, outs ReplicaOutputStreams, offset long, nbytes long, flags int) : void in class org.apache.hadoop.hdfs.server.datanode.SimulatedFSDataset |
From |
To |
|
Change Parameter Type fd : FileDescriptor to outs : ReplicaOutputStreams in method public submitBackgroundSyncFileRangeRequest(block ExtendedBlock, outs ReplicaOutputStreams, offset long, nbytes long, flags int) : void in class org.apache.hadoop.hdfs.server.datanode.fsdataset.FsDatasetSpi |
From |
To |
|
Change Parameter Type fd : FileDescriptor to streams : ReplicaOutputStreams in method public submitSyncFileRangeRequest(volume FsVolumeImpl, streams ReplicaOutputStreams, offset long, nbytes long, flags int) : void in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetAsyncDiskService |
From |
To |
|
Change Parameter Type fd : FileDescriptor to outs : ReplicaOutputStreams in method public submitBackgroundSyncFileRangeRequest(block ExtendedBlock, outs ReplicaOutputStreams, offset long, nbytes long, flags int) : void in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |
|
Extract And Move Method public readDataFully(buf byte[], off int, len int) : void extracted from private sendPacket(pkt ByteBuffer, maxChunks int, out OutputStream, transferTo boolean, throttler DataTransferThrottler) : int in class org.apache.hadoop.hdfs.server.datanode.BlockSender & moved to class org.apache.hadoop.hdfs.server.datanode.fsdataset.ReplicaInputStreams |
From |
To |
|
Extract And Move Method public closeChecksumStream() : void extracted from private readChecksum(buf byte[], checksumOffset int, checksumLen int) : void in class org.apache.hadoop.hdfs.server.datanode.BlockSender & moved to class org.apache.hadoop.hdfs.server.datanode.fsdataset.ReplicaInputStreams |
From |
To |
|
Extract And Move Method public closeStreams() : void extracted from public close() : void in class org.apache.hadoop.hdfs.server.datanode.BlockSender & moved to class org.apache.hadoop.hdfs.server.datanode.fsdataset.ReplicaInputStreams |
From |
To |
|
Extract And Move Method public renameBlock(newBlockFile File) : void extracted from public moveReplicaFrom(oldReplicaInfo ReplicaInfo, newBlkFile File) : void in class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline & moved to class org.apache.hadoop.hdfs.server.datanode.LocalReplica |
From |
To |
|
Extract And Move Method public writeToDisk(b byte[], off int, len int) : long extracted from private receivePacket() : int in class org.apache.hadoop.hdfs.server.datanode.BlockReceiver & moved to class org.apache.hadoop.hdfs.server.datanode.fsdataset.ReplicaOutputStreams |
From |
To |
|
Extract And Move Method public dropCacheBehindWrites(identifier String, offset long, len long, flags int) : void extracted from private manageWriterOsCache(offsetInBlock long) : void in class org.apache.hadoop.hdfs.server.datanode.BlockReceiver & moved to class org.apache.hadoop.hdfs.server.datanode.fsdataset.ReplicaOutputStreams |
From |
To |
|
Extract And Move Method public closeDataStream() : void extracted from public close() : void in class org.apache.hadoop.hdfs.server.datanode.BlockReceiver & moved to class org.apache.hadoop.hdfs.server.datanode.fsdataset.ReplicaOutputStreams |
From |
To |
|
Extract And Move Method public renameMeta(newMetaFile File) : void extracted from public moveReplicaFrom(oldReplicaInfo ReplicaInfo, newBlkFile File) : void in class org.apache.hadoop.hdfs.server.datanode.LocalReplicaInPipeline & moved to class org.apache.hadoop.hdfs.server.datanode.LocalReplica |
From |
To |
|
Extract And Move Method public skipDataFully(len long) : void extracted from private validateIntegrityAndSetLength(blockFile File, genStamp long) : long in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.BlockPoolSlice & moved to class org.apache.hadoop.hdfs.server.datanode.fsdataset.ReplicaInputStreams |
From |
To |
|
Extract And Move Method public readDataFully(buf byte[], off int, len int) : void extracted from private validateIntegrityAndSetLength(blockFile File, genStamp long) : long in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.BlockPoolSlice & moved to class org.apache.hadoop.hdfs.server.datanode.fsdataset.ReplicaInputStreams |
From |
To |
|
Extract And Move Method public syncFileRangeIfPossible(offset long, nbytes long, flags int) : void extracted from private manageWriterOsCache(offsetInBlock long) : void in class org.apache.hadoop.hdfs.server.datanode.BlockReceiver & moved to class org.apache.hadoop.hdfs.server.datanode.fsdataset.ReplicaOutputStreams |
From |
To |
|
Extract And Move Method public skipChecksumFully(len long) : void extracted from private validateIntegrityAndSetLength(blockFile File, genStamp long) : long in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.BlockPoolSlice & moved to class org.apache.hadoop.hdfs.server.datanode.fsdataset.ReplicaInputStreams |
From |
To |
|
Rename Parameter fd : FileDescriptor to outs : ReplicaOutputStreams in method public submitBackgroundSyncFileRangeRequest(block ExtendedBlock, outs ReplicaOutputStreams, offset long, nbytes long, flags int) : void in class org.apache.hadoop.hdfs.server.datanode.SimulatedFSDataset |
From |
To |
|
Rename Parameter fd : FileDescriptor to outs : ReplicaOutputStreams in method public submitBackgroundSyncFileRangeRequest(block ExtendedBlock, outs ReplicaOutputStreams, offset long, nbytes long, flags int) : void in class org.apache.hadoop.hdfs.server.datanode.fsdataset.FsDatasetSpi |
From |
To |
|
Rename Parameter fd : FileDescriptor to streams : ReplicaOutputStreams in method public submitSyncFileRangeRequest(volume FsVolumeImpl, streams ReplicaOutputStreams, offset long, nbytes long, flags int) : void in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetAsyncDiskService |
From |
To |
|
Rename Parameter fd : FileDescriptor to outs : ReplicaOutputStreams in method public submitBackgroundSyncFileRangeRequest(block ExtendedBlock, outs ReplicaOutputStreams, offset long, nbytes long, flags int) : void in class org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.FsDatasetImpl |
From |
To |