@InterfaceAudience.Public public class WALPlayer extends org.apache.hadoop.conf.Configured implements org.apache.hadoop.util.Tool
Modifier and Type | Class and Description |
---|---|
protected static class |
WALPlayer.Counter
Enum for map metrics.
|
(package private) static class |
WALPlayer.WALKeyValueMapper
A mapper that just writes out KeyValues.
|
protected static class |
WALPlayer.WALMapper
A mapper that writes out
Mutation to be directly applied to a running HBase instance. |
Modifier and Type | Field and Description |
---|---|
static String |
BULK_OUTPUT_CONF_KEY |
static String |
IGNORE_MISSING_FILES |
static String |
INPUT_FILES_SEPARATOR_KEY |
private static String |
JOB_NAME_CONF_KEY |
private static org.slf4j.Logger |
LOG |
static String |
MULTI_TABLES_SUPPORT |
(package private) static String |
NAME |
static String |
TABLE_MAP_KEY |
static String |
TABLES_KEY |
protected static String |
tableSeparator |
Modifier | Constructor and Description |
---|---|
|
WALPlayer() |
protected |
WALPlayer(org.apache.hadoop.conf.Configuration c) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapreduce.Job |
createSubmittableJob(String[] args)
Sets up the actual job.
|
private List<TableName> |
getTableNameList(String[] tables) |
static void |
main(String[] args)
Main entry point.
|
int |
run(String[] args) |
(package private) void |
setupTime(org.apache.hadoop.conf.Configuration conf,
String option) |
private void |
usage(String errorMsg)
Print usage
|
private static final org.slf4j.Logger LOG
static final String NAME
public static final String BULK_OUTPUT_CONF_KEY
public static final String TABLES_KEY
public static final String TABLE_MAP_KEY
public static final String INPUT_FILES_SEPARATOR_KEY
public static final String IGNORE_MISSING_FILES
public static final String MULTI_TABLES_SUPPORT
protected static final String tableSeparator
private static final String JOB_NAME_CONF_KEY
public WALPlayer()
protected WALPlayer(org.apache.hadoop.conf.Configuration c)
void setupTime(org.apache.hadoop.conf.Configuration conf, String option) throws IOException
IOException
public org.apache.hadoop.mapreduce.Job createSubmittableJob(String[] args) throws IOException
args
- The command line parameters.IOException
- When setting up the job fails.private List<TableName> getTableNameList(String[] tables)
private void usage(String errorMsg)
errorMsg
- Error message. Can be null.public static void main(String[] args) throws Exception
args
- The command line parameters.Exception
- When running the job fails.Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.