protected class DBOutputFormat.DBRecordWriter extends Object implements RecordWriter<K,V>
Modifier | Constructor and Description |
---|---|
protected |
DBRecordWriter(Connection connection,
PreparedStatement statement) |
Modifier and Type | Method and Description |
---|---|
void |
close(Reporter reporter)
Close this
RecordWriter to future operations. |
void |
write(K key,
V value)
Writes a key/value pair.
|
protected DBRecordWriter(Connection connection, PreparedStatement statement) throws SQLException
SQLException
public void close(Reporter reporter) throws IOException
RecordWriter
to future operations.close
in interface RecordWriter<K extends DBWritable,V>
reporter
- facility to report progress.IOException
public void write(K key, V value) throws IOException
write
in interface RecordWriter<K extends DBWritable,V>
key
- the key to write.value
- the value to write.IOException
Copyright © 2010 The Apache Software Foundation