@@ -0,0 +1,1011 @@
+package com.twitter.elephantbird.pig.store;%0A%0Aimport java.io.IOException;%0A%0Aimport org.apache.hadoop.io.compress.BZip2Codec;%0Aimport org.apache.hadoop.mapreduce.Job;%0Aimport org.apache.pig.builtin.PigStorage;%0A%0A/**%0A * Enables bzip2 compression for storage.%3Cbr%3E%0A * This is similar to:%0A * %3Cpre%3E%0A *   set output.compression.enabled true;%0A *   set output.compression.codec org.apache.hadoop.io.compress.BZip2Codec;%0A *   storage alias using PigStorage();%0A * %3C/pre%3E%0A */%0Apublic class Bz2PigStorage extends PigStorage %7B%0A  // Ideally, PigStorage it self should take more options like compression%0A  // codec etc.%0A  public Bz2PigStorage() %7B%0A    super();%0A  %7D%0A%0A  public Bz2PigStorage(String delimiter) %7B%0A    super(delimiter);%0A  %7D%0A%0A  @Override%0A  public void setStoreLocation(String location, Job job) throws IOException %7B%0A    job.getConfiguration().set(%22output.compression.enabled%22, %22true%22);%0A    job.getConfiguration().set(%22output.compression.codec%22, BZip2Codec.class.getName());%0A    super.setStoreLocation(location, job);%0A  %7D%0A%0A%7D%0A

Add Bz2PigStorage.