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

Class AbstractNodeWriter<TValue>

java.lang.Object

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

org.apache.jena.hadoop.rdf.io.output.writers.AbstractNodeWriter<TValue>

Type Parameters:

TValue -

Direct Known Subclasses:

NTriplesNodeWriter

public abstract class AbstractNodeWriter<TValue>
extends org.apache.hadoop.mapreduce.RecordWriter<NodeWritable,TValue>

Abstract implementation of a record writer which writes pairs of nodes and arbitrary values to text based files

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_SEPARATOR Default separator written between nodes and their associated values

Constructor Summary

Constructors

Constructor and Description
AbstractNodeWriter(Writer writer) Creates a new tuple writer using the default NTriples node formatter
AbstractNodeWriter(Writer writer, NodeFormatter formatter) Creates a new tuple writer

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_SEPARATOR

public static final String DEFAULT_SEPARATOR

Default separator written between nodes and their associated values

See Also:

Constant Field Values

Constructor Detail

AbstractNodeWriter

public AbstractNodeWriter(Writer writer)

Creates a new tuple writer using the default NTriples node formatter

Parameters:

writer - Writer

AbstractNodeWriter

public AbstractNodeWriter(Writer writer,
                          NodeFormatter formatter)

Creates a new tuple writer

Parameters:

writer - Writer

formatter - Node formatter

Method Detail

write

public final void write(NodeWritable key,
                        TValue value)

Specified by:

write in class org.apache.hadoop.mapreduce.RecordWriter<NodeWritable,TValue>

close

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

Specified by:

close in class org.apache.hadoop.mapreduce.RecordWriter<NodeWritable,TValue>