org.apache.jena.hadoop.rdf.io.input.readers

Class AbstractLineBasedNodeTupleReader<TValue,T extends AbstractNodeTupleWritable<TValue>>

java.lang.Object

org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,T>

org.apache.jena.hadoop.rdf.io.input.readers.AbstractLineBasedNodeTupleReader<TValue,T>

Type Parameters:

TValue -

T - Writable tuple type

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

AbstractLineBasedQuadReader, AbstractLineBasedTripleReader

public abstract class AbstractLineBasedNodeTupleReader<TValue,T extends AbstractNodeTupleWritable<TValue>>
extends org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,T>

An abstract implementation of a record reader that reads records from line based tuple formats. This only supports reading from file splits currently.

The keys produced are the position of the line in the file and the values will be node tuples

Constructor Summary

Constructors

Constructor and Description
AbstractLineBasedNodeTupleReader()

Method Summary

Modifier and Type	Method and Description
void	close()
org.apache.hadoop.io.LongWritable	getCurrentKey()
T	getCurrentValue()
float	getProgress()
void	initialize(org.apache.hadoop.mapreduce.InputSplit genericSplit, org.apache.hadoop.mapreduce.TaskAttemptContext context)
boolean	nextKeyValue()

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractLineBasedNodeTupleReader

public AbstractLineBasedNodeTupleReader()

Method Detail

initialize

public final void initialize(org.apache.hadoop.mapreduce.InputSplit genericSplit,
                             org.apache.hadoop.mapreduce.TaskAttemptContext context)
                      throws IOException

Specified by:

initialize in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,T extends AbstractNodeTupleWritable<TValue>>

Throws:

IOException

nextKeyValue

public final boolean nextKeyValue()
                           throws IOException

Specified by:

nextKeyValue in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,T extends AbstractNodeTupleWritable<TValue>>

Throws:

IOException

getCurrentKey

public org.apache.hadoop.io.LongWritable getCurrentKey()

Specified by:

getCurrentKey in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,T extends AbstractNodeTupleWritable<TValue>>

getCurrentValue

public T getCurrentValue()

Specified by:

getCurrentValue in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,T extends AbstractNodeTupleWritable<TValue>>

getProgress

public float getProgress()

Specified by:

getProgress in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,T extends AbstractNodeTupleWritable<TValue>>

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,T extends AbstractNodeTupleWritable<TValue>>

Throws:

IOException