| Package | Description | 
|---|---|
| org.apache.avro.file | A container file for Avro data. | 
| org.apache.avro.hadoop.file | |
| org.apache.avro.mapreduce | 
| Modifier and Type | Method and Description | 
|---|---|
| static CodecFactory | CodecFactory. addCodec(String name,
        CodecFactory c)Adds a new codec implementation. | 
| static CodecFactory | CodecFactory. bzip2Codec()bzip2 codec. | 
| static CodecFactory | CodecFactory. deflateCodec(int compressionLevel)Deflate codec, with specific compression. | 
| static CodecFactory | CodecFactory. fromString(String s)Maps a codec name into a CodecFactory. | 
| static CodecFactory | CodecFactory. nullCodec()Null codec, for no compression. | 
| static CodecFactory | CodecFactory. snappyCodec()Snappy codec. | 
| static CodecFactory | CodecFactory. xzCodec(int compressionLevel)XZ codec, with specific compression. | 
| static CodecFactory | CodecFactory. zstandardCodec(int level)zstandard codec, with specific compression level. | 
| static CodecFactory | CodecFactory. zstandardCodec(int level,
              boolean useChecksum)zstandard codec, with specific compression level. | 
| Modifier and Type | Method and Description | 
|---|---|
| static CodecFactory | CodecFactory. addCodec(String name,
        CodecFactory c)Adds a new codec implementation. | 
| DataFileWriter<D> | DataFileWriter. setCodec(CodecFactory c)Configures this writer to use the given codec. | 
| Modifier and Type | Method and Description | 
|---|---|
| static CodecFactory | HadoopCodecFactory. fromHadoopString(String hadoopCodecClass)Maps a hadoop codec name into a CodecFactory. | 
| CodecFactory | SortedKeyValueFile.Writer.Options. getCodec()Return the compression codec. | 
| Modifier and Type | Method and Description | 
|---|---|
| SortedKeyValueFile.Writer.Options | SortedKeyValueFile.Writer.Options. withCodec(CodecFactory codec)Set the compression codec. | 
| Modifier and Type | Method and Description | 
|---|---|
| protected static CodecFactory | AvroOutputFormatBase. getCompressionCodec(TaskAttemptContext context)Gets the configured compression codec from the task context. | 
| Modifier and Type | Method and Description | 
|---|---|
| protected RecordWriter<AvroKey<T>,NullWritable> | AvroKeyOutputFormat.RecordWriterFactory. create(Schema writerSchema,
      GenericData dataModel,
      CodecFactory compressionCodec,
      OutputStream outputStream,
      int syncInterval)Creates a new record writer instance. | 
| Constructor and Description | 
|---|
| AvroKeyRecordWriter(Schema writerSchema,
                   GenericData dataModel,
                   CodecFactory compressionCodec,
                   OutputStream outputStream)Constructor. | 
| AvroKeyRecordWriter(Schema writerSchema,
                   GenericData dataModel,
                   CodecFactory compressionCodec,
                   OutputStream outputStream,
                   int syncInterval)Constructor. | 
| AvroKeyValueRecordWriter(AvroDatumConverter<K,?> keyConverter,
                        AvroDatumConverter<V,?> valueConverter,
                        GenericData dataModel,
                        CodecFactory compressionCodec,
                        OutputStream outputStream)Constructor. | 
| AvroKeyValueRecordWriter(AvroDatumConverter<K,?> keyConverter,
                        AvroDatumConverter<V,?> valueConverter,
                        GenericData dataModel,
                        CodecFactory compressionCodec,
                        OutputStream outputStream,
                        int syncInterval)Constructor. | 
Copyright © 2009–2020 The Apache Software Foundation. All rights reserved.