K
- The type of key to write.V
- The type of value to write.public abstract class AvroOutputFormatBase<K,V> extends FileOutputFormat<K,V>
FileOutputFormat.Counter
BASE_OUTPUT_NAME, COMPRESS, COMPRESS_CODEC, COMPRESS_TYPE, OUTDIR, PART
Constructor and Description |
---|
AvroOutputFormatBase() |
Modifier and Type | Method and Description |
---|---|
protected OutputStream |
getAvroFileOutputStream(TaskAttemptContext context)
Gets the target output stream where the Avro container file should be written.
|
protected static CodecFactory |
getCompressionCodec(TaskAttemptContext context)
Gets the configured compression codec from the task context.
|
protected static int |
getSyncInterval(TaskAttemptContext context)
Gets the configured sync interval from the task context.
|
checkOutputSpecs, getCompressOutput, getDefaultWorkFile, getOutputCommitter, getOutputCompressorClass, getOutputName, getOutputPath, getPathForWorkFile, getRecordWriter, getUniqueFile, getWorkOutputPath, setCompressOutput, setOutputCompressorClass, setOutputName, setOutputPath
protected static CodecFactory getCompressionCodec(TaskAttemptContext context)
context
- The task attempt context.protected OutputStream getAvroFileOutputStream(TaskAttemptContext context) throws IOException
context
- The task attempt context.IOException
protected static int getSyncInterval(TaskAttemptContext context)
context
- The task attempt context.Copyright © 2009–2017 The Apache Software Foundation. All rights reserved.