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

Class AbstractLineBasedNodeTupleWriter<TKey,TValue,T extends AbstractNodeTupleWritable<TValue>>

java.lang.Object

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

org.apache.jena.hadoop.rdf.io.output.writers.AbstractLineBasedNodeTupleWriter<TKey,TValue,T>

Type Parameters:

TKey - Key type

TValue - Tuple type

T - Writable node tuple type

Direct Known Subclasses:

AbstractLineBasedQuadWriter, AbstractLineBasedTripleWriter

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

An abstract implementation of a record writer that writes records to a line based tuple formats.

The implementation only writes the value portion of the key value pair since it is the value portion that is used to convey the node tuples

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_SEPARATOR Default separator written between nodes
static String	DEFAULT_TERMINATOR Default terminator written at the end of each line

Constructor Summary

Constructors

Constructor and Description
AbstractLineBasedNodeTupleWriter(Writer writer) Creates a new tuple writer using the default NTriples node formatter
AbstractLineBasedNodeTupleWriter(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(TKey key, T 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

See Also:

Constant Field Values

DEFAULT_TERMINATOR

public static final String DEFAULT_TERMINATOR

Default terminator written at the end of each line

See Also:

Constant Field Values

Constructor Detail

AbstractLineBasedNodeTupleWriter

public AbstractLineBasedNodeTupleWriter(Writer writer)

Creates a new tuple writer using the default NTriples node formatter

Parameters:

writer - Writer

AbstractLineBasedNodeTupleWriter

public AbstractLineBasedNodeTupleWriter(Writer writer,
                                        NodeFormatter formatter)

Creates a new tuple writer

Parameters:

writer - Writer

formatter - Node formatter

Method Detail

write

public void write(TKey key,
                  T value)

Specified by:

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

close

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

Specified by:

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