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