core/src/main/java/com/twitter/elephantbird/mapreduce/output/LzoOutputFormat.java
protected DataOutputStream getOutputStream(TaskAttemptContext job)
                  throws IOException, InterruptedException {

    return LzoUtils.getIndexedLzoOutputStream(
                      HadoopCompat.getConfiguration(job),
                      getDefaultWorkFile(job, LzopCodec.DEFAULT_LZO_EXTENSION));
  }
protected DataOutputStream getOutputStream(TaskAttemptContext job)
                  throws IOException, InterruptedException {

    return LzoUtils.getIndexedLzoOutputStream(
                      HadoopCompat.getConfiguration(job),
                      getDefaultWorkFile(job, LzopCodec.DEFAULT_LZO_EXTENSION));
  }
protected DataOutputStream getOutputStream ( TaskAttemptContext job ) throws IOException , InterruptedException { return LzoUtils . getIndexedLzoOutputStream ( HadoopCompat . getConfiguration ( job ) , getDefaultWorkFile ( job , LzopCodec . DEFAULT_LZO_EXTENSION ) ) ; }
Helper method to create lzo output file needed to create RecordWriter
Helper method to create lzo output file needed to create RecordWriter