T
- The Java type of the Trevni data to write.public class AvroTrevniKeyRecordWriter<T> extends AvroTrevniRecordWriterBase<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 Schema |
initSchema(TaskAttemptContext context)
Use the task context to construct a schema for writing
|
void |
write(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(AvroKey<T> key, NullWritable value) throws IOException, InterruptedException
write
in class RecordWriter<AvroKey<T>,NullWritable>
IOException
InterruptedException
protected Schema initSchema(TaskAttemptContext context)
initSchema
in class AvroTrevniRecordWriterBase<AvroKey<T>,NullWritable,T>
Copyright © 2009–2020 The Apache Software Foundation. All rights reserved.