public class AvroGenericRecordWriter extends Object implements FileSinkOperator.RecordWriter
Constructor and Description |
---|
AvroGenericRecordWriter(org.apache.avro.file.DataFileWriter<org.apache.avro.generic.GenericRecord> dfw) |
Modifier and Type | Method and Description |
---|---|
void |
close(boolean abort) |
void |
write(org.apache.hadoop.io.Writable writable) |
public AvroGenericRecordWriter(org.apache.avro.file.DataFileWriter<org.apache.avro.generic.GenericRecord> dfw)
public void write(org.apache.hadoop.io.Writable writable) throws IOException
write
in interface FileSinkOperator.RecordWriter
IOException
public void close(boolean abort) throws IOException
close
in interface FileSinkOperator.RecordWriter
IOException
Copyright © 2022 The Apache Software Foundation. All rights reserved.