net.sansa_stack.hadoop.output

Class FileOutputFormatTrig2<TKey>

java.lang.Object

org.apache.hadoop.mapreduce.OutputFormat<K,V>

org.apache.hadoop.mapreduce.lib.output.FileOutputFormat<TKey,T>

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

org.apache.jena.hadoop.rdf.io.output.AbstractStreamRdfNodeTupleOutputFormat<TKey,org.apache.jena.sparql.core.Quad,org.apache.jena.hadoop.rdf.types.QuadWritable>

net.sansa_stack.hadoop.output.FileOutputFormatTrig2<TKey>

public class FileOutputFormatTrig2<TKey>
extends org.apache.jena.hadoop.rdf.io.output.AbstractStreamRdfNodeTupleOutputFormat<TKey,org.apache.jena.sparql.core.Quad,org.apache.jena.hadoop.rdf.types.QuadWritable>

Not yet used; the idea is to provide an improved version of elepha's TrigOutputFormat

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.lib.output.FileOutputFormat

org.apache.hadoop.mapreduce.lib.output.FileOutputFormat.Counter

Field Summary

Fields inherited from class org.apache.hadoop.mapreduce.lib.output.FileOutputFormat

BASE_OUTPUT_NAME, COMPRESS, COMPRESS_CODEC, COMPRESS_TYPE, OUTDIR, PART

Constructor Summary

Constructors

Constructor and Description
FileOutputFormatTrig2()

Method Summary

Modifier and Type	Method and Description
protected String	getFileExtension()
protected org.apache.hadoop.mapreduce.RecordWriter<TKey,org.apache.jena.hadoop.rdf.types.QuadWritable>	getRecordWriter(org.apache.jena.riot.system.StreamRDF stream, Writer writer, org.apache.hadoop.conf.Configuration config)
protected org.apache.jena.riot.system.StreamRDF	getStream(Writer writer, org.apache.hadoop.conf.Configuration config)

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

getRecordWriter

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

getRecordWriter

Methods inherited from class org.apache.hadoop.mapreduce.lib.output.FileOutputFormat

checkOutputSpecs, getCompressOutput, getDefaultWorkFile, getOutputCommitter, getOutputCompressorClass, getOutputName, getOutputPath, getPathForWorkFile, getUniqueFile, getWorkOutputPath, setCompressOutput, setOutputCompressorClass, setOutputName, setOutputPath

Methods inherited from class java.lang.Object

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

Constructor Detail

FileOutputFormatTrig2

public FileOutputFormatTrig2()

Method Detail

getRecordWriter

protected org.apache.hadoop.mapreduce.RecordWriter<TKey,org.apache.jena.hadoop.rdf.types.QuadWritable> getRecordWriter(org.apache.jena.riot.system.StreamRDF stream,
                                                                                                                       Writer writer,
                                                                                                                       org.apache.hadoop.conf.Configuration config)

Specified by:

getRecordWriter in class org.apache.jena.hadoop.rdf.io.output.AbstractStreamRdfNodeTupleOutputFormat<TKey,org.apache.jena.sparql.core.Quad,org.apache.jena.hadoop.rdf.types.QuadWritable>

getStream

protected org.apache.jena.riot.system.StreamRDF getStream(Writer writer,
                                                          org.apache.hadoop.conf.Configuration config)

Specified by:

getStream in class org.apache.jena.hadoop.rdf.io.output.AbstractStreamRdfNodeTupleOutputFormat<TKey,org.apache.jena.sparql.core.Quad,org.apache.jena.hadoop.rdf.types.QuadWritable>

getFileExtension

protected String getFileExtension()

Specified by:

getFileExtension in class org.apache.jena.hadoop.rdf.io.output.AbstractNodeTupleOutputFormat<TKey,org.apache.jena.sparql.core.Quad,org.apache.jena.hadoop.rdf.types.QuadWritable>