org.apache.jena.hadoop.rdf.io.output.writers

Class QuadsToTriplesWriter<TKey>

java.lang.Object

org.apache.hadoop.mapreduce.RecordWriter<TKey,QuadWritable>

org.apache.jena.hadoop.rdf.io.output.writers.QuadsToTriplesWriter<TKey>

Type Parameters:

TKey - Key type

public class QuadsToTriplesWriter<TKey>
extends org.apache.hadoop.mapreduce.RecordWriter<TKey,QuadWritable>

A record writer that converts quads into triples by stripping off the graph field

Constructor Summary

Constructors

Constructor and Description
QuadsToTriplesWriter(org.apache.hadoop.mapreduce.RecordWriter<TKey,TripleWritable> tripleWriter) Creates a new writer

Method Summary

Modifier and Type	Method and Description
void	close(org.apache.hadoop.mapreduce.TaskAttemptContext context)
void	write(TKey key, QuadWritable value)

Methods inherited from class java.lang.Object

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

Constructor Detail

QuadsToTriplesWriter

public QuadsToTriplesWriter(org.apache.hadoop.mapreduce.RecordWriter<TKey,TripleWritable> tripleWriter)

Creates a new writer

Parameters:

tripleWriter - Triple writer to use

Method Detail

write

public void write(TKey key,
                  QuadWritable value)
           throws IOException,
                  InterruptedException

Specified by:

write in class org.apache.hadoop.mapreduce.RecordWriter<TKey,QuadWritable>

Throws:

IOException

InterruptedException

close

public void close(org.apache.hadoop.mapreduce.TaskAttemptContext context)
           throws IOException,
                  InterruptedException

Specified by:

close in class org.apache.hadoop.mapreduce.RecordWriter<TKey,QuadWritable>

Throws:

IOException

InterruptedException