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

Class AbstractStreamRdfNodeTupleWriter<TKey,TTuple,TValue extends AbstractNodeTupleWritable<TTuple>>

java.lang.Object

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

org.apache.jena.hadoop.rdf.io.output.writers.AbstractStreamRdfNodeTupleWriter<TKey,TTuple,TValue>

Direct Known Subclasses:

StreamRdfQuadWriter, StreamRdfTripleWriter

public abstract class AbstractStreamRdfNodeTupleWriter<TKey,TTuple,TValue extends AbstractNodeTupleWritable<TTuple>>
extends org.apache.hadoop.mapreduce.RecordWriter<TKey,TValue>

Constructor Summary

Constructors

Constructor and Description
AbstractStreamRdfNodeTupleWriter(StreamRDF stream, Writer writer)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractStreamRdfNodeTupleWriter

public AbstractStreamRdfNodeTupleWriter(StreamRDF stream,
                                        Writer writer)

Method Detail

close

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

Specified by:

close in class org.apache.hadoop.mapreduce.RecordWriter<TKey,TValue extends AbstractNodeTupleWritable<TTuple>>

Throws:

IOException

write

public void write(TKey key,
                  TValue value)

Specified by:

write in class org.apache.hadoop.mapreduce.RecordWriter<TKey,TValue extends AbstractNodeTupleWritable<TTuple>>