org.apache.hadoop.mapreduce.lib.db

Class DBOutputFormat.DBRecordWriter

java.lang.Object

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

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

Direct Known Subclasses:

DBOutputFormat.DBRecordWriter

Enclosing class:

DBOutputFormat<K extends DBWritable,V>

public class DBOutputFormat.DBRecordWriter
extends RecordWriter<K,V>

A RecordWriter that writes the reduce output to a SQL table

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
void	close(TaskAttemptContext context) Close this RecordWriter to future operations.
java.sql.Connection	getConnection()
java.sql.PreparedStatement	getStatement()
void	write(K key, V value) Writes a key/value pair.

Methods inherited from class java.lang.Object

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

Constructor Detail

DBOutputFormat.DBRecordWriter

public DBOutputFormat.DBRecordWriter()
                              throws java.sql.SQLException

Throws:

java.sql.SQLException

DBOutputFormat.DBRecordWriter

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

Throws:

java.sql.SQLException

Method Detail

getConnection

public java.sql.Connection getConnection()

getStatement

public java.sql.PreparedStatement getStatement()

close

public void close(TaskAttemptContext context)
           throws java.io.IOException

Close this RecordWriter to future operations.

Specified by:

close in class RecordWriter<K extends DBWritable,V>

Parameters:

context - the context of the task

Throws:

java.io.IOException

write

public void write(K key,
         V value)
           throws java.io.IOException

Writes a key/value pair.

Specified by:

write in class RecordWriter<K extends DBWritable,V>

Parameters:

key - the key to write.

value - the value to write.

Throws:

java.io.IOException