public class JdbcRecordWriter extends Object implements FileSinkOperator.RecordWriter
Constructor and Description |
---|
JdbcRecordWriter(org.apache.hadoop.mapreduce.lib.db.DBOutputFormat.DBRecordWriter writer) |
Modifier and Type | Method and Description |
---|---|
void |
close(boolean abort) |
void |
write(org.apache.hadoop.io.Writable w) |
public JdbcRecordWriter(org.apache.hadoop.mapreduce.lib.db.DBOutputFormat.DBRecordWriter writer)
public void write(org.apache.hadoop.io.Writable w) 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.