@@ -0,0 +1,1172 @@
+package com.twitter.elephantbird.pig.store;%0A%0Aimport java.io.IOException;%0Aimport org.apache.hadoop.mapreduce.Job;%0Aimport org.apache.pig.builtin.PigStorage;%0Aimport com.hadoop.compression.lzo.LzopCodec;%0A%0A/**%0A * A wrapper for %7B@link PigStorage%7D that forces LZO compression for%0A * storing. Loading LZO files is supported natively by PIG as long%0A * as lzo codec is configured.%0A *%0A * This is equivalent to:%0A * %3Cpre%3E%0A *   set output.compression.enabled true;%0A *   set output.compression.codec com.hadoop.compression.lzo.LzopCodec;%0A *   storage alias using PigStorage();%0A * %3C/pre%3E%0A */%0Apublic class LzoPigStorage extends PigStorage %7B%0A%0A  public LzoPigStorage() %7B%0A    super();%0A  %7D%0A%0A  public LzoPigStorage(String delimiter) %7B%0A    super(delimiter);%0A  %7D%0A%0A  @Override%0A  public void setStoreLocation(String location, Job job) throws IOException %7B%0A    // looks like each context gets different job. modifying conf here%0A    // does not affect subsequent store statements in the script.%0A    job.getConfiguration().set(%22output.compression.enabled%22, %22true%22);%0A    job.getConfiguration().set(%22output.compression.code%22, LzopCodec.class.getName());%0A    super.setStoreLocation(location, job);%0A  %7D%0A%7D%0A

add LzoPigStorage (extension of an implementation by gerritjvv).