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

Class BlockedNTriplesReader

java.lang.Object

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

org.apache.jena.hadoop.rdf.io.input.readers.AbstractBlockBasedNodeTupleReader<org.apache.jena.graph.Triple,TripleWritable>

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

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

All Implemented Interfaces:

Closeable, AutoCloseable

public class BlockedNTriplesReader
extends AbstractBlockBasedTripleReader

A record record for NTriples

This is a hybrid of the NTriplesReader and the WholeFileNTriplesReader in that it does not process individual lines rather it processes the inputs in blocks of lines parsing the whole block rather than individual lines. This provides a compromise between the higher parser setup of creating more parsers and the benefit of being able to split input files over multiple mappers.

Constructor Summary

Constructors

Constructor and Description
BlockedNTriplesReader()

Method Summary

Methods inherited from class org.apache.jena.hadoop.rdf.io.input.readers.AbstractBlockBasedNodeTupleReader

close, getCurrentKey, getCurrentValue, getProgress, initialize, nextKeyValue

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockedNTriplesReader

public BlockedNTriplesReader()