org.vertexium.accumulo.mapreduce

Class AccumuloVertexInputFormat

java.lang.Object

org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.Text,TValue>

org.vertexium.accumulo.mapreduce.AccumuloElementInputFormatBase<Vertex>

org.vertexium.accumulo.mapreduce.AccumuloVertexInputFormat

public class AccumuloVertexInputFormat
extends AccumuloElementInputFormatBase<Vertex>

Constructor Summary

Constructors

Constructor and Description
AccumuloVertexInputFormat()

Method Summary

Modifier and Type	Method and Description
protected Vertex	createElementFromRow(AccumuloGraph graph, org.apache.accumulo.core.util.PeekingIterator<Map.Entry<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>> row, Authorizations authorizations)
static Vertex	createVertex(AccumuloGraph graph, Iterator<Map.Entry<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>> row, Authorizations authorizations)
static void	setInputInfo(org.apache.hadoop.mapreduce.Job job, AccumuloGraph graph, String instanceName, String zooKeepers, String principal, org.apache.accumulo.core.client.security.tokens.AuthenticationToken token, String[] authorizations)

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

createRecordReader, getSplits, makePropertiesFromElementData, setFetchHints, setInputInfo

Methods inherited from class java.lang.Object

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

Constructor Detail

AccumuloVertexInputFormat

public AccumuloVertexInputFormat()

Method Detail

setInputInfo

public static void setInputInfo(org.apache.hadoop.mapreduce.Job job,
                                AccumuloGraph graph,
                                String instanceName,
                                String zooKeepers,
                                String principal,
                                org.apache.accumulo.core.client.security.tokens.AuthenticationToken token,
                                String[] authorizations)
                         throws org.apache.accumulo.core.client.AccumuloSecurityException

Throws:

org.apache.accumulo.core.client.AccumuloSecurityException

createElementFromRow

protected Vertex createElementFromRow(AccumuloGraph graph,
                                      org.apache.accumulo.core.util.PeekingIterator<Map.Entry<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>> row,
                                      Authorizations authorizations)

Specified by:

createElementFromRow in class AccumuloElementInputFormatBase<Vertex>

createVertex

public static Vertex createVertex(AccumuloGraph graph,
                                  Iterator<Map.Entry<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>> row,
                                  Authorizations authorizations)