org.vertexium.titan.hadoop.accumulo

Class AccumuloVertexiumInputFormat

java.lang.Object

org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.NullWritable,com.thinkaurelius.titan.hadoop.FaunusVertex>

org.vertexium.titan.hadoop.accumulo.AccumuloVertexiumInputFormat

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable

public class AccumuloVertexiumInputFormat
extends org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.NullWritable,com.thinkaurelius.titan.hadoop.FaunusVertex>
implements org.apache.hadoop.conf.Configurable

Constructor Summary

Constructors

Constructor and Description
AccumuloVertexiumInputFormat()

Method Summary

Modifier and Type	Method and Description
static void	configure(org.apache.hadoop.mapreduce.Job job)
org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.NullWritable,com.thinkaurelius.titan.hadoop.FaunusVertex>	createRecordReader(org.apache.hadoop.mapreduce.InputSplit inputSplit, org.apache.hadoop.mapreduce.TaskAttemptContext taskAttemptContext)
org.apache.hadoop.conf.Configuration	getConf()
List<org.apache.hadoop.mapreduce.InputSplit>	getSplits(org.apache.hadoop.mapreduce.JobContext context)
void	setConf(org.apache.hadoop.conf.Configuration config)

Methods inherited from class java.lang.Object

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

Constructor Detail

AccumuloVertexiumInputFormat

public AccumuloVertexiumInputFormat()

Method Detail

getSplits

public List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext context)
                                                       throws IOException,
                                                              InterruptedException

Specified by:

getSplits in class org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.NullWritable,com.thinkaurelius.titan.hadoop.FaunusVertex>

Throws:

IOException

InterruptedException

configure

public static void configure(org.apache.hadoop.mapreduce.Job job)

setConf

public void setConf(org.apache.hadoop.conf.Configuration config)

Specified by:

setConf in interface org.apache.hadoop.conf.Configurable

getConf

public org.apache.hadoop.conf.Configuration getConf()

Specified by:

getConf in interface org.apache.hadoop.conf.Configurable

createRecordReader

public org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.NullWritable,com.thinkaurelius.titan.hadoop.FaunusVertex> createRecordReader(org.apache.hadoop.mapreduce.InputSplit inputSplit,
                                                                                                                                                  org.apache.hadoop.mapreduce.TaskAttemptContext taskAttemptContext)
                                                                                                                                           throws IOException,
                                                                                                                                                  InterruptedException

Specified by:

createRecordReader in class org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.NullWritable,com.thinkaurelius.titan.hadoop.FaunusVertex>

Throws:

IOException

InterruptedException