org.apache.hadoop.mapred.lib.db

Class DBOutputFormat.DBRecordWriter

java.lang.Object

org.apache.hadoop.mapreduce.RecordWriter<K,V>

org.apache.hadoop.mapreduce.lib.db.DBOutputFormat.DBRecordWriter

org.apache.hadoop.mapred.lib.db.DBOutputFormat.DBRecordWriter

All Implemented Interfaces:

RecordWriter<K,V>

Enclosing class:

DBOutputFormat<K extends DBWritable,V>

protected class DBOutputFormat.DBRecordWriter
extends DBOutputFormat.DBRecordWriter
implements RecordWriter<K,V>

A RecordWriter that writes the reduce output to a SQL table

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DBOutputFormat.DBRecordWriter(java.sql.Connection connection, java.sql.PreparedStatement statement)

Method Summary

Methods

Modifier and Type	Method and Description
void	close(Reporter reporter) Close this RecordWriter to future operations.

Methods inherited from class org.apache.hadoop.mapreduce.lib.db.DBOutputFormat.DBRecordWriter

close, getConnection, getStatement, write

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.mapred.RecordWriter

write

Constructor Detail

DBOutputFormat.DBRecordWriter

protected DBOutputFormat.DBRecordWriter(java.sql.Connection connection,
                             java.sql.PreparedStatement statement)
                                 throws java.sql.SQLException

Throws:

java.sql.SQLException

Method Detail

close

public void close(Reporter reporter)
           throws java.io.IOException

Close this RecordWriter to future operations.

Specified by:

close in interface RecordWriter<K extends DBWritable,V>

Parameters:

reporter - facility to report progress.

Throws:

java.io.IOException