public class AvroParquetOutputFormat extends ParquetOutputFormat<org.apache.avro.generic.IndexedRecord>
OutputFormat
for Parquet files.BLOCK_SIZE, COMPRESSION, DICTIONARY_PAGE_SIZE, ENABLE_DICTIONARY, PAGE_SIZE, VALIDATION, WRITE_SUPPORT_CLASS, WRITER_VERSION
Constructor and Description |
---|
AvroParquetOutputFormat() |
Modifier and Type | Method and Description |
---|---|
static void |
setSchema(org.apache.hadoop.mapreduce.Job job,
org.apache.avro.Schema schema)
Set the Avro schema to use for writing.
|
getBlockSize, getBlockSize, getCompression, getCompression, getDictionaryPageSize, getDictionaryPageSize, getEnableDictionary, getEnableDictionary, getOutputCommitter, getPageSize, getPageSize, getRecordWriter, getRecordWriter, getRecordWriter, getValidation, getValidation, getWriterVersion, getWriteSupport, getWriteSupportClass, isCompressionSet, isCompressionSet, setBlockSize, setCompression, setDictionaryPageSize, setEnableDictionary, setPageSize, setValidation, setValidation, setWriteSupportClass, setWriteSupportClass
checkOutputSpecs, getCompressOutput, getDefaultWorkFile, getOutputCompressorClass, getOutputName, getOutputPath, getPathForWorkFile, getUniqueFile, getWorkOutputPath, setCompressOutput, setOutputCompressorClass, setOutputName, setOutputPath
public static void setSchema(org.apache.hadoop.mapreduce.Job job, org.apache.avro.Schema schema)
job
- schema
- AvroParquetInputFormat.setAvroReadSchema(org.apache.hadoop.mapreduce.Job, org.apache.avro.Schema)
Copyright © 2015. All rights reserved.