org.vertexium.accumulo.mapreduce

Class AccumuloMutationElementMapper<KEYIN,VALUEIN>

java.lang.Object

org.apache.hadoop.mapreduce.Mapper<KEYIN,VALUEIN,KEYOUT,VALUEOUT>

org.vertexium.accumulo.mapreduce.ElementMapper<KEYIN,VALUEIN,org.apache.hadoop.io.Text,org.apache.accumulo.core.data.Mutation>

org.vertexium.accumulo.mapreduce.AccumuloMutationElementMapper<KEYIN,VALUEIN>

public abstract class AccumuloMutationElementMapper<KEYIN,VALUEIN>
extends ElementMapper<KEYIN,VALUEIN,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

Field Summary

Fields inherited from class org.vertexium.accumulo.mapreduce.ElementMapper

GRAPH_CONFIG_PREFIX

Constructor Summary

Constructors

Constructor and Description
AccumuloMutationElementMapper()

Method Summary

Modifier and Type	Method and Description
protected org.apache.hadoop.io.Text	getKey(org.apache.hadoop.mapreduce.Mapper.Context context, org.apache.hadoop.io.Text tableName, org.apache.accumulo.core.data.Mutation m)
protected void	saveDataMutation(org.apache.hadoop.mapreduce.Mapper.Context context, org.apache.hadoop.io.Text dataTableName, org.apache.accumulo.core.data.Mutation m)
protected void	saveEdgeMutation(org.apache.hadoop.mapreduce.Mapper.Context context, org.apache.hadoop.io.Text edgesTableName, org.apache.accumulo.core.data.Mutation m)
protected void	saveExtendedDataMutation(org.apache.hadoop.mapreduce.Mapper.Context context, org.apache.hadoop.io.Text tableName, org.apache.accumulo.core.data.Mutation m)
protected void	saveVertexMutation(org.apache.hadoop.mapreduce.Mapper.Context context, org.apache.hadoop.io.Text verticesTableName, org.apache.accumulo.core.data.Mutation m)

Methods inherited from class org.vertexium.accumulo.mapreduce.ElementMapper

addEdge, getGraph, getIdGenerator, prepareEdge, prepareEdge, prepareEdge, prepareEdge, prepareEdge, prepareVertex, prepareVertex, prepareVertex, setup

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

cleanup, map, run

Methods inherited from class java.lang.Object

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

Constructor Detail

AccumuloMutationElementMapper

public AccumuloMutationElementMapper()

Method Detail

saveDataMutation

protected void saveDataMutation(org.apache.hadoop.mapreduce.Mapper.Context context,
                                org.apache.hadoop.io.Text dataTableName,
                                org.apache.accumulo.core.data.Mutation m)
                         throws IOException,
                                InterruptedException

Specified by:

saveDataMutation in class ElementMapper<KEYIN,VALUEIN,org.apache.hadoop.io.Text,org.apache.accumulo.core.data.Mutation>

Throws:

IOException

InterruptedException

saveEdgeMutation

protected void saveEdgeMutation(org.apache.hadoop.mapreduce.Mapper.Context context,
                                org.apache.hadoop.io.Text edgesTableName,
                                org.apache.accumulo.core.data.Mutation m)
                         throws IOException,
                                InterruptedException

Specified by:

saveEdgeMutation in class ElementMapper<KEYIN,VALUEIN,org.apache.hadoop.io.Text,org.apache.accumulo.core.data.Mutation>

Throws:

IOException

InterruptedException

saveVertexMutation

protected void saveVertexMutation(org.apache.hadoop.mapreduce.Mapper.Context context,
                                  org.apache.hadoop.io.Text verticesTableName,
                                  org.apache.accumulo.core.data.Mutation m)
                           throws IOException,
                                  InterruptedException

Specified by:

saveVertexMutation in class ElementMapper<KEYIN,VALUEIN,org.apache.hadoop.io.Text,org.apache.accumulo.core.data.Mutation>

Throws:

IOException

InterruptedException

saveExtendedDataMutation

protected void saveExtendedDataMutation(org.apache.hadoop.mapreduce.Mapper.Context context,
                                        org.apache.hadoop.io.Text tableName,
                                        org.apache.accumulo.core.data.Mutation m)
                                 throws IOException,
                                        InterruptedException

Specified by:

saveExtendedDataMutation in class ElementMapper<KEYIN,VALUEIN,org.apache.hadoop.io.Text,org.apache.accumulo.core.data.Mutation>

Throws:

IOException

InterruptedException

getKey

protected org.apache.hadoop.io.Text getKey(org.apache.hadoop.mapreduce.Mapper.Context context,
                                           org.apache.hadoop.io.Text tableName,
                                           org.apache.accumulo.core.data.Mutation m)