class MultiRFileOutputFormatter extends FileOutputFormat<BulkIngestKey,Value> {

    public static void setCompressionType(Configuration conf, String compressionType) {
        if (compressionType != null) {
            if (!("snappy".equals(compressionType) || "lzo".equals(compressionType) || "gz".equals(compressionType) || "none".equals(compressionType)))
                
                throw new IllegalArgumentException("compressionType must be one of snappy, lzo, gz, or none");
            conf.set(COMPRESSION_TYPE, compressionType);
        }
    }

}