| 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. 
 | 
static CodecFactory | 
CodecFactory.zstandardCodec(int level,
              boolean useChecksum,
              boolean useBufferPool)
zstandard codec, with specific compression level, checksum, and bufferPool 
 | 
| 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(org.apache.hadoop.mapreduce.TaskAttemptContext context)
Gets the configured compression codec from the task context. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected org.apache.hadoop.mapreduce.RecordWriter<AvroKey<T>,org.apache.hadoop.io.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–2021 The Apache Software Foundation. All rights reserved.