protected static class MultiTableOutputFormat.MultiTableRecordWriter extends org.apache.hadoop.mapreduce.RecordWriter<ImmutableBytesWritable,Mutation>
Modifier and Type | Field and Description |
---|---|
(package private) org.apache.hadoop.conf.Configuration |
conf |
(package private) Connection |
connection |
private static org.slf4j.Logger |
LOG |
(package private) Map<ImmutableBytesWritable,BufferedMutator> |
mutatorMap |
(package private) boolean |
useWriteAheadLogging |
Constructor and Description |
---|
MultiTableRecordWriter(org.apache.hadoop.conf.Configuration conf,
boolean useWriteAheadLogging)
n * HBaseConfiguration to used n * whether to use write ahead logging.
|
Modifier and Type | Method and Description |
---|---|
void |
close(org.apache.hadoop.mapreduce.TaskAttemptContext context) |
(package private) BufferedMutator |
getBufferedMutator(ImmutableBytesWritable tableName)
n * the name of the table, as a string
|
void |
write(ImmutableBytesWritable tableName,
Mutation action)
Writes an action (Put or Delete) to the specified table.
|
private static final org.slf4j.Logger LOG
Connection connection
Map<ImmutableBytesWritable,BufferedMutator> mutatorMap
org.apache.hadoop.conf.Configuration conf
boolean useWriteAheadLogging
public MultiTableRecordWriter(org.apache.hadoop.conf.Configuration conf, boolean useWriteAheadLogging) throws IOException
IOException
BufferedMutator getBufferedMutator(ImmutableBytesWritable tableName) throws IOException
IOException
public void close(org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException
close
in class org.apache.hadoop.mapreduce.RecordWriter<ImmutableBytesWritable,Mutation>
IOException
public void write(ImmutableBytesWritable tableName, Mutation action) throws IOException
write
in class org.apache.hadoop.mapreduce.RecordWriter<ImmutableBytesWritable,Mutation>
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.