protected static class TableOutputFormat.TableRecordWriter extends Object implements org.apache.hadoop.mapred.RecordWriter<ImmutableBytesWritable,Put>
Modifier and Type | Field and Description |
---|---|
private Connection |
conn |
private BufferedMutator |
m_mutator |
Constructor and Description |
---|
TableRecordWriter(BufferedMutator mutator)
Deprecated.
since 2.0.0 and will be removed in 3.0.0. Please use
#TableRecordWriter(JobConf) instead. This version does not clean up
connections and will leak connections (removed in 2.0). |
TableRecordWriter(org.apache.hadoop.mapred.JobConf job)
Instantiate a TableRecordWriter with a BufferedMutator for batch writing.
|
Modifier and Type | Method and Description |
---|---|
void |
close(org.apache.hadoop.mapred.Reporter reporter) |
void |
write(ImmutableBytesWritable key,
Put value) |
private BufferedMutator m_mutator
private Connection conn
@Deprecated public TableRecordWriter(BufferedMutator mutator) throws IOException
#TableRecordWriter(JobConf)
instead. This version does not clean up
connections and will leak connections (removed in 2.0).IOException
public TableRecordWriter(org.apache.hadoop.mapred.JobConf job) throws IOException
IOException
public void close(org.apache.hadoop.mapred.Reporter reporter) throws IOException
close
in interface org.apache.hadoop.mapred.RecordWriter<ImmutableBytesWritable,Put>
IOException
public void write(ImmutableBytesWritable key, Put value) throws IOException
write
in interface org.apache.hadoop.mapred.RecordWriter<ImmutableBytesWritable,Put>
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.