Class WALPlayer.WALKeyValueMapper
- Enclosing class:
- WALPlayer
static class WALPlayer.WALKeyValueMapper
extends org.apache.hadoop.mapreduce.Mapper<WALKey,WALEdit,org.apache.hadoop.io.WritableComparable<?>,Cell>
A mapper that just writes out KeyValues. This one can be used together with
CellSortReducer
-
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.Mapper
org.apache.hadoop.mapreduce.Mapper.Context
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate boolean
private boolean
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
map
(WALKey key, WALEdit value, org.apache.hadoop.mapreduce.Mapper<WALKey, WALEdit, org.apache.hadoop.io.WritableComparable<?>, Cell>.org.apache.hadoop.mapreduce.Mapper.Context context) void
setup
(org.apache.hadoop.mapreduce.Mapper<WALKey, WALEdit, org.apache.hadoop.io.WritableComparable<?>, Cell>.org.apache.hadoop.mapreduce.Mapper.Context context) private org.apache.hadoop.io.WritableComparable<?>
wrapKey
(byte[] key, ExtendedCell cell) Methods inherited from class org.apache.hadoop.mapreduce.Mapper
cleanup, run
-
Field Details
-
tableSet
-
multiTableSupport
-
diskBasedSortingEnabled
-
-
Constructor Details
-
WALKeyValueMapper
-
-
Method Details
-
map
public void map(WALKey key, WALEdit value, org.apache.hadoop.mapreduce.Mapper<WALKey, WALEdit, throws IOExceptionorg.apache.hadoop.io.WritableComparable<?>, Cell>.org.apache.hadoop.mapreduce.Mapper.Context context) - Overrides:
map
in classorg.apache.hadoop.mapreduce.Mapper<WALKey,
WALEdit, org.apache.hadoop.io.WritableComparable<?>, Cell> - Throws:
IOException
-
setup
public void setup(org.apache.hadoop.mapreduce.Mapper<WALKey, WALEdit, throws IOExceptionorg.apache.hadoop.io.WritableComparable<?>, Cell>.org.apache.hadoop.mapreduce.Mapper.Context context) - Overrides:
setup
in classorg.apache.hadoop.mapreduce.Mapper<WALKey,
WALEdit, org.apache.hadoop.io.WritableComparable<?>, Cell> - Throws:
IOException
-
wrapKey
-