public class AvroGenericRecordWriter extends java.lang.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(Writable writable) |
public AvroGenericRecordWriter(org.apache.avro.file.DataFileWriter<org.apache.avro.generic.GenericRecord> dfw)
public void write(Writable writable) throws java.io.IOException
write
in interface FileSinkOperator.RecordWriter
java.io.IOException
public void close(boolean abort) throws java.io.IOException
close
in interface FileSinkOperator.RecordWriter
java.io.IOException
Copyright © 2012 The Apache Software Foundation