T
- The Java type of the Trevni data to write.public class AvroTrevniKeyRecordWriter<T> extends AvroTrevniRecordWriterBase<org.apache.avro.mapred.AvroKey<T>,org.apache.hadoop.io.NullWritable,T>
EXT, meta, META_PREFIX, part, schema, writer
Constructor and Description |
---|
AvroTrevniKeyRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
protected org.apache.avro.Schema |
initSchema(org.apache.hadoop.mapreduce.TaskAttemptContext context)
Use the task context to construct a schema for writing
|
void |
write(org.apache.avro.mapred.AvroKey<T> key,
org.apache.hadoop.io.NullWritable value) |
close, flush
public AvroTrevniKeyRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException
context
- The TaskAttempContext to supply the writer with information form the job configurationIOException
public void write(org.apache.avro.mapred.AvroKey<T> key, org.apache.hadoop.io.NullWritable value) throws IOException, InterruptedException
write
in class org.apache.hadoop.mapreduce.RecordWriter<org.apache.avro.mapred.AvroKey<T>,org.apache.hadoop.io.NullWritable>
IOException
InterruptedException
protected org.apache.avro.Schema initSchema(org.apache.hadoop.mapreduce.TaskAttemptContext context)
initSchema
in class AvroTrevniRecordWriterBase<org.apache.avro.mapred.AvroKey<T>,org.apache.hadoop.io.NullWritable,T>
Copyright © 2009–2021 Cloudera. All rights reserved.