public Configuration initializeConf ( String [ ] keys , Configuration conf , FileSystem fs ) throws IOException { Configuration newConf = new Configuration ( conf ) ; if ( fs == null ) { fs = FileSystem . get ( conf ) ; } String suffix = fs . getUri ( ) . getAuthority ( ) ; for ( String key : keys ) { String value = conf . get ( key + "." + suffix ) ; if ( value != null ) { newConf . set ( key , value ) ; } } return newConf ; }
Initialize the config based on the given Filesystem