class CopyOutputFormat extends TextOutputFormat<K, V> {

  @Override
  public OutputCommitter getOutputCommitter(TaskAttemptContext context) throws IOException {
    return new CopyCommitter(getOutputPath(context), context);
  }

}