T
- The Java type of the Trevni data to write.public class AvroTrevniKeyRecordWriter<T> extends AvroTrevniRecordWriterBase<org.apache.avro.mapred.AvroKey<T>,NullWritable,T>
EXT, meta, META_PREFIX, part, schema, writer
Constructor and Description |
---|
AvroTrevniKeyRecordWriter(TaskAttemptContext context)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
protected org.apache.avro.Schema |
initSchema(TaskAttemptContext context)
Use the task context to construct a schema for writing
|
void |
write(org.apache.avro.mapred.AvroKey<T> key,
NullWritable value) |
close, flush
public AvroTrevniKeyRecordWriter(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, NullWritable value) throws IOException, InterruptedException
write
in class RecordWriter<org.apache.avro.mapred.AvroKey<T>,NullWritable>
IOException
InterruptedException
protected org.apache.avro.Schema initSchema(TaskAttemptContext context)
initSchema
in class AvroTrevniRecordWriterBase<org.apache.avro.mapred.AvroKey<T>,NullWritable,T>
Copyright © 2009–2023 The Apache Software Foundation. All rights reserved.