org.vertexium.accumulo.migrations

Class MRMigrationBase.MRMigrationMapperBase<TKey,TValue>

java.lang.Object

org.apache.hadoop.mapreduce.Mapper<TKey,TValue,org.apache.hadoop.io.Text,org.apache.accumulo.core.data.Mutation>

org.vertexium.accumulo.migrations.MRMigrationBase.MRMigrationMapperBase<TKey,TValue>

Enclosing class:

MRMigrationBase

protected abstract static class MRMigrationBase.MRMigrationMapperBase<TKey,TValue>
extends org.apache.hadoop.mapreduce.Mapper<TKey,TValue,org.apache.hadoop.io.Text,org.apache.accumulo.core.data.Mutation>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.Mapper

org.apache.hadoop.mapreduce.Mapper.Context

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	MRMigrationMapperBase()

Method Summary

Modifier and Type	Method and Description
protected org.apache.hadoop.io.Text	getOutputTableNameText()
org.vertexium.VertexiumSerializer	getVertexiumSerializer()
protected void	map(TKey key, TValue value, org.apache.hadoop.mapreduce.Mapper.Context context)
protected abstract void	safeMap(TKey key, TValue value, org.apache.hadoop.mapreduce.Mapper.Context context)
protected void	setup(org.apache.hadoop.mapreduce.Mapper.Context context)

Methods inherited from class org.apache.hadoop.mapreduce.Mapper

cleanup, run

Methods inherited from class java.lang.Object

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

Constructor Detail

MRMigrationMapperBase

protected MRMigrationMapperBase()

Method Detail

setup

protected void setup(org.apache.hadoop.mapreduce.Mapper.Context context)
              throws IOException,
                     InterruptedException

Overrides:

setup in class org.apache.hadoop.mapreduce.Mapper<TKey,TValue,org.apache.hadoop.io.Text,org.apache.accumulo.core.data.Mutation>

Throws:

IOException

InterruptedException

map

protected void map(TKey key,
                   TValue value,
                   org.apache.hadoop.mapreduce.Mapper.Context context)
            throws IOException,
                   InterruptedException

Overrides:

map in class org.apache.hadoop.mapreduce.Mapper<TKey,TValue,org.apache.hadoop.io.Text,org.apache.accumulo.core.data.Mutation>

Throws:

IOException

InterruptedException

safeMap

protected abstract void safeMap(TKey key,
                                TValue value,
                                org.apache.hadoop.mapreduce.Mapper.Context context)
                         throws Exception

Throws:

Exception

getVertexiumSerializer

public org.vertexium.VertexiumSerializer getVertexiumSerializer()

getOutputTableNameText

protected org.apache.hadoop.io.Text getOutputTableNameText()