Package ca.uhn.fhir.util.rdf

Class StreamRDFDedup

java.lang.Object

ca.uhn.fhir.util.rdf.StreamRDFDedup

All Implemented Interfaces:

org.apache.jena.riot.system.StreamRDF

public class StreamRDFDedup
extends Object
implements org.apache.jena.riot.system.StreamRDF

Wraps another StreamRDF and attempts to remove duplicate triples and quads. To maintain streaming, duplicates are only removed within a sliding window of configurable size. Default size is 10000 triples and quads.

Constructor Summary

Constructors

Constructor	Description
StreamRDFDedup(org.apache.jena.riot.system.StreamRDF wrapped)
StreamRDFDedup(org.apache.jena.riot.system.StreamRDF wrapped, int windowSize)

Method Summary

Modifier and Type	Method	Description
void	base(String base)
void	finish()
void	prefix(String prefix, String iri)
void	quad(org.apache.jena.sparql.core.Quad quad)
void	start()
void	triple(org.apache.jena.graph.Triple triple)

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamRDFDedup

public StreamRDFDedup(org.apache.jena.riot.system.StreamRDF wrapped)

StreamRDFDedup

public StreamRDFDedup(org.apache.jena.riot.system.StreamRDF wrapped,
                      int windowSize)

Method Detail

start

public void start()

Specified by:

start in interface org.apache.jena.riot.system.StreamRDF

triple

public void triple(org.apache.jena.graph.Triple triple)

Specified by:

triple in interface org.apache.jena.riot.system.StreamRDF

quad

public void quad(org.apache.jena.sparql.core.Quad quad)

Specified by:

quad in interface org.apache.jena.riot.system.StreamRDF

base

public void base(String base)

Specified by:

base in interface org.apache.jena.riot.system.StreamRDF

prefix

public void prefix(String prefix,
                   String iri)

Specified by:

prefix in interface org.apache.jena.riot.system.StreamRDF

finish

public void finish()

Specified by:

finish in interface org.apache.jena.riot.system.StreamRDF