cascading2/src/main/java/com/twitter/elephantbird/cascading2/scheme/CombinedSequenceFile.java
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);
    }
  }
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);
    }
  }
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
We can allow overriding the compression settings for just this scheme here