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