Constructor and Description |
---|
Import() |
Modifier and Type | Method and Description |
---|---|
static void |
addFilterAndArguments(org.apache.hadoop.conf.Configuration conf,
Class<? extends Filter> clazz,
List<String> args)
Add a Filter to be instantiated on import
|
static void |
configureCfRenaming(org.apache.hadoop.conf.Configuration conf,
Map<String,String> renameMap)
Sets a configuration property with key
CF_RENAME_PROP in conf that tells
the mapper how to rename column families. |
static org.apache.hadoop.mapreduce.Job |
createSubmittableJob(org.apache.hadoop.conf.Configuration conf,
String[] args)
Sets up the actual job.
|
static void |
main(String[] args)
Main entry point.
|
public static void configureCfRenaming(org.apache.hadoop.conf.Configuration conf, Map<String,String> renameMap)
Sets a configuration property with key CF_RENAME_PROP
in conf that tells
the mapper how to rename column families.
Alternately, instead of calling this function, you could set the configuration key
CF_RENAME_PROP
yourself. The value should look like
srcCf1:destCf1,srcCf2:destCf2,..... This would have the same effect on the mapper behavior.
conf
- the Configuration in which the CF_RENAME_PROP
key will be
setrenameMap
- a mapping from source CF names to destination CF namespublic static void addFilterAndArguments(org.apache.hadoop.conf.Configuration conf, Class<? extends Filter> clazz, List<String> args)
conf
- Configuration to update (will be passed to the job)clazz
- Filter
subclass to instantiate on the server.args
- List of arguments to pass to the filter on instantiationpublic static org.apache.hadoop.mapreduce.Job createSubmittableJob(org.apache.hadoop.conf.Configuration conf, String[] args) throws IOException
conf
- The current configuration.args
- The command line parameters.IOException
- When setting up the job fails.Copyright © 2013 The Apache Software Foundation. All rights reserved.