BlockInfo [ ] setReplication ( String src , short replication , int [ ] oldReplication ) throws IOException { waitForReady ( ) ; BlockInfo [ ] fileBlocks = unprotectedSetReplication ( src , replication , oldReplication ) ; if ( fileBlocks != null ) // log replication change fsImage . getEditLog ( ) . logSetReplication ( src , replication ) ; return fileBlocks ; }
Set file replication