public static class MobRefReporter.MobRefReducer extends org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.Text,ImmutableBytesWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
Modifier and Type | Field and Description |
---|---|
(package private) org.apache.hadoop.fs.Path |
archive |
(package private) Base64.Encoder |
base64 |
(package private) org.apache.hadoop.io.Text |
DATALOSS_HLINK_DANGLING |
(package private) org.apache.hadoop.io.Text |
DATALOSS_MISSING |
(package private) org.apache.hadoop.io.Text |
DATALOSS_MISSING_IOE |
(package private) org.apache.hadoop.io.Text |
INCONSISTENT_ARCHIVE_BAD_LINK |
(package private) org.apache.hadoop.io.Text |
INCONSISTENT_ARCHIVE_IOE |
(package private) org.apache.hadoop.io.Text |
INCONSISTENT_ARCHIVE_STALE |
(package private) org.apache.hadoop.fs.Path |
mob |
(package private) String |
mobRegion |
(package private) org.apache.hadoop.io.Text |
OK_HLINK_CLONE |
(package private) org.apache.hadoop.io.Text |
OK_HLINK_RESTORE |
(package private) org.apache.hadoop.io.Text |
OK_MOB_DIR |
(package private) String |
seperator |
(package private) TableName |
table |
Constructor and Description |
---|
MobRefReducer() |
Modifier and Type | Method and Description |
---|---|
private org.apache.hadoop.io.Text |
encodeRows(org.apache.hadoop.mapreduce.Reducer.Context context,
org.apache.hadoop.io.Text key,
Iterable<ImmutableBytesWritable> rows)
reuses the passed Text key.
|
void |
reduce(org.apache.hadoop.io.Text key,
Iterable<ImmutableBytesWritable> rows,
org.apache.hadoop.mapreduce.Reducer.Context context) |
void |
setup(org.apache.hadoop.mapreduce.Reducer.Context context) |
org.apache.hadoop.fs.Path mob
org.apache.hadoop.fs.Path archive
final org.apache.hadoop.io.Text OK_MOB_DIR
final org.apache.hadoop.io.Text OK_HLINK_RESTORE
final org.apache.hadoop.io.Text OK_HLINK_CLONE
final org.apache.hadoop.io.Text INCONSISTENT_ARCHIVE_BAD_LINK
final org.apache.hadoop.io.Text INCONSISTENT_ARCHIVE_STALE
final org.apache.hadoop.io.Text INCONSISTENT_ARCHIVE_IOE
final org.apache.hadoop.io.Text DATALOSS_MISSING
final org.apache.hadoop.io.Text DATALOSS_HLINK_DANGLING
final org.apache.hadoop.io.Text DATALOSS_MISSING_IOE
final Base64.Encoder base64
public MobRefReducer()
public void setup(org.apache.hadoop.mapreduce.Reducer.Context context) throws IOException, InterruptedException
setup
in class org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.Text,ImmutableBytesWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
IOException
InterruptedException
public void reduce(org.apache.hadoop.io.Text key, Iterable<ImmutableBytesWritable> rows, org.apache.hadoop.mapreduce.Reducer.Context context) throws IOException, InterruptedException
reduce
in class org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.Text,ImmutableBytesWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
IOException
InterruptedException
private org.apache.hadoop.io.Text encodeRows(org.apache.hadoop.mapreduce.Reducer.Context context, org.apache.hadoop.io.Text key, Iterable<ImmutableBytesWritable> rows) throws IOException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.