@Override
  public RecordWriter<WritableComparable, AvroGenericRecordWritable>
  getRecordWriter(FileSystem ignored, JobConf job, String fileName,
      Progressable progress) throws IOException {
    return new WrapperRecordWriter<WritableComparable, AvroGenericRecordWritable>(job,progress,fileName);
  }
Write to an Avro file from a Hive process.
ql/src/java/org/apache/hadoop/hive/ql/io/avro/AvroContainerOutputFormat.java