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.
|
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–2017 The Apache Software Foundation. All rights reserved.