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

Class BatchedTriGWriter<TKey>

java.lang.Object

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

org.apache.jena.hadoop.rdf.io.output.writers.AbstractBatchedNodeTupleWriter<TKey,Quad,QuadWritable>

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

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

Type Parameters:

TKey - Key type

public class BatchedTriGWriter<TKey>
extends AbstractBatchedQuadWriter<TKey>

A record writer for TriG that uses the batched approach, note that this approach will produce invalid data when blank nodes span batches

Constructor Summary

Constructors

Constructor and Description
BatchedTriGWriter(Writer writer, long batchSize) Creates a new record writer

Method Summary

Methods inherited from class org.apache.jena.hadoop.rdf.io.output.writers.AbstractBatchedNodeTupleWriter

close, write

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchedTriGWriter

public BatchedTriGWriter(Writer writer,
                         long batchSize)

Creates a new record writer

Parameters:

writer - Writer

batchSize - Batch size