@InterfaceStability.Evolving public class DBOutputFormat.DBRecordWriter extends RecordWriter<K,V>
构造器和说明 |
---|
DBOutputFormat.DBRecordWriter() |
DBOutputFormat.DBRecordWriter(Connection connection,
PreparedStatement statement) |
限定符和类型 | 方法和说明 |
---|---|
void |
close(TaskAttemptContext context)
Close this
RecordWriter to future operations. |
Connection |
getConnection() |
PreparedStatement |
getStatement() |
void |
write(K key,
V value)
Writes a key/value pair.
|
public DBOutputFormat.DBRecordWriter() throws SQLException
SQLException
public DBOutputFormat.DBRecordWriter(Connection connection, PreparedStatement statement) throws SQLException
SQLException
public Connection getConnection()
public PreparedStatement getStatement()
public void close(TaskAttemptContext context) throws IOException
RecordWriter
to future operations.close
在类中 RecordWriter<K extends DBWritable,V>
context
- the context of the taskIOException
public void write(K key, V value) throws IOException
write
在类中 RecordWriter<K extends DBWritable,V>
key
- the key to write.value
- the value to write.IOException
Copyright © 2009 The Apache Software Foundation