private static void updateJobConfForLocalSettings ( JobConf conf ) { String localSetCompressionEnabled = conf . get ( COMPRESS_ENABLE ) ; if ( localSetCompressionEnabled != null ) { conf . set ( MR_COMPRESS_ENABLE , localSetCompressionEnabled ) ; } String localSetCompressionType = conf . get ( COMPRESS_TYPE ) ; if ( localSetCompressionType != null ) { conf . set ( MR_COMPRESS_TYPE , localSetCompressionType ) ; } String localSetCompressionCodec = conf . get ( COMPRESS_CODEC ) ; if ( localSetCompressionCodec != null ) { conf . set ( MR_COMPRESS_CODEC , localSetCompressionCodec ) ; } }
We can allow overriding the compression settings for just this scheme here