public class HivePassThroughRecordWriter<K extends <any>,V extends Writable> extends java.lang.Object implements FileSinkOperator.RecordWriter
Constructor and Description |
---|
HivePassThroughRecordWriter(<any> writer) |
Modifier and Type | Method and Description |
---|---|
void |
close(boolean abort) |
void |
write(Writable r) |
public void write(Writable r) 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