Uses of Class
org.apache.avro.file.CodecFactory
Package
Description
A container file for Avro data.
-
Uses of CodecFactory in org.apache.avro.file
Modifier and TypeMethodDescriptionstatic 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. compressionLevel should be between 1 and 9, inclusive.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. compressionLevel should be between 1 and 9, inclusive.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 bufferPoolModifier and TypeMethodDescriptionstatic CodecFactory
CodecFactory.addCodec
(String name, CodecFactory c) Adds a new codec implementation.DataFileWriter.setCodec
(CodecFactory c) Configures this writer to use the given codec. -
Uses of CodecFactory in org.apache.avro.hadoop.file
Modifier and TypeMethodDescriptionstatic CodecFactory
HadoopCodecFactory.fromHadoopString
(String hadoopCodecClass) Maps a hadoop codec name into a CodecFactory.SortedKeyValueFile.Writer.Options.getCodec()
Return the compression codec.Modifier and TypeMethodDescriptionSortedKeyValueFile.Writer.Options.withCodec
(CodecFactory codec) Set the compression codec. -
Uses of CodecFactory in org.apache.avro.mapreduce
Modifier and TypeMethodDescriptionprotected static CodecFactory
AvroOutputFormatBase.getCompressionCodec
(TaskAttemptContext context) Gets the configured compression codec from the task context.Modifier and TypeMethodDescriptionprotected RecordWriter
<AvroKey<T>, NullWritable> AvroKeyOutputFormat.RecordWriterFactory.create
(Schema writerSchema, GenericData dataModel, CodecFactory compressionCodec, OutputStream outputStream, int syncInterval) Creates a new record writer instance.ModifierConstructorDescriptionAvroKeyRecordWriter
(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.