org.vertexium.accumulo.migrations

Class MRMigrationBase

java.lang.Object

org.apache.hadoop.conf.Configured

org.vertexium.accumulo.migrations.MRMigrationBase

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.util.Tool

public abstract class MRMigrationBase
extends org.apache.hadoop.conf.Configured
implements org.apache.hadoop.util.Tool

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	MRMigrationBase.MRMigrationMapperBase<TKey,TValue>
protected static class	MRMigrationBase.Opts
protected static class	MRMigrationBase.OptsWithTableName

Constructor Summary

Constructors

Constructor and Description
MRMigrationBase()

Method Summary

Modifier and Type	Method and Description
protected MRMigrationBase.Opts	createOpts()
static AccumuloGraphConfiguration	getAccumuloGraphConfiguration(org.apache.hadoop.conf.Configuration conf)
protected Class	getInputFormatClass()
protected abstract Class<? extends org.apache.hadoop.mapreduce.Mapper>	getMigrationMapperClass()
static String	getOutputTableName(org.apache.hadoop.conf.Configuration conf)
static org.vertexium.VertexiumSerializer	getVertexiumSerializer(org.apache.hadoop.conf.Configuration conf)
protected static void	run(MRMigrationBase mr, String[] args)
int	run(String[] args)

Methods inherited from class org.apache.hadoop.conf.Configured

getConf, setConf

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.conf.Configurable

getConf, setConf

Constructor Detail

MRMigrationBase

public MRMigrationBase()

Method Detail

run

protected static void run(MRMigrationBase mr,
                          String[] args)
                   throws Exception

Throws:

Exception

getVertexiumSerializer

public static org.vertexium.VertexiumSerializer getVertexiumSerializer(org.apache.hadoop.conf.Configuration conf)

getOutputTableName

public static String getOutputTableName(org.apache.hadoop.conf.Configuration conf)

getAccumuloGraphConfiguration

public static AccumuloGraphConfiguration getAccumuloGraphConfiguration(org.apache.hadoop.conf.Configuration conf)

run

public int run(String[] args)
        throws Exception

Specified by:

run in interface org.apache.hadoop.util.Tool

Throws:

Exception

getInputFormatClass

protected Class getInputFormatClass()

createOpts

protected MRMigrationBase.Opts createOpts()

getMigrationMapperClass

protected abstract Class<? extends org.apache.hadoop.mapreduce.Mapper> getMigrationMapperClass()