parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ParquetOutputFormat.java
@Override
  public RecordWriter<Void, T> getRecordWriter(TaskAttemptContext taskAttemptContext)
      throws IOException, InterruptedException {

    final Configuration conf = getConfiguration(taskAttemptContext);

    CompressionCodecName codec = getCodec(taskAttemptContext);
    String extension = codec.getExtension() + ".parquet";
    Path file = getDefaultWorkFile(taskAttemptContext, extension);
    return getRecordWriter(conf, file, codec);
  }
@Override
  public RecordWriter<Void, T> getRecordWriter(TaskAttemptContext taskAttemptContext)
      throws IOException, InterruptedException {

    final Configuration conf = getConfiguration(taskAttemptContext);

    CompressionCodecName codec = getCodec(taskAttemptContext);
    String extension = codec.getExtension() + ".parquet";
    Path file = getDefaultWorkFile(taskAttemptContext, extension);
    return getRecordWriter(conf, file, codec);
  }
@ Override public RecordWriter < Void , T > getRecordWriter ( TaskAttemptContext taskAttemptContext ) throws IOException , InterruptedException { final Configuration conf = getConfiguration ( taskAttemptContext ) ; CompressionCodecName codec = getCodec ( taskAttemptContext ) ; String extension = codec . getExtension ( ) + ".parquet" ; Path file = getDefaultWorkFile ( taskAttemptContext , extension ) ; return getRecordWriter ( conf , file , codec ) ; }
{@inheritDoc}
{