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
- Enclosing class:
- DBOutputFormat<K extends DBWritable,V>
@InterfaceStability.Evolving
public class DBOutputFormat.DBRecordWriter
- extends RecordWriter<K,V>
A RecordWriter that writes the reduce output to a SQL table
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DBOutputFormat.DBRecordWriter
public DBOutputFormat.DBRecordWriter()
throws SQLException
- Throws:
SQLException
DBOutputFormat.DBRecordWriter
public DBOutputFormat.DBRecordWriter(Connection connection,
PreparedStatement statement)
throws SQLException
- Throws:
SQLException
getConnection
public Connection getConnection()
getStatement
public PreparedStatement getStatement()
close
public void close(TaskAttemptContext context)
throws 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:
IOException
write
public void write(K key,
V value)
throws 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:
IOException
Copyright © 2009 The Apache Software Foundation