org.apache.jena.riot.lang
Class CollectorStreamBase<T>

java.lang.Object
  org.apache.jena.riot.lang.CollectorStreamBase<T>

Type Parameters:

T - Type of the value stored in the collection

All Implemented Interfaces:

StreamRDF

Direct Known Subclasses:

CollectorStreamQuads, CollectorStreamTriples, CollectorStreamTuples

public abstract class CollectorStreamBase<T>
extends Object
implements StreamRDF

Base class for StreamRDF implementations which store received objects in a Collection. The resulting collection can be retrieved via the getCollected() method. Implementations are suitable for single-threaded parsing, for use with small data or distributed computing frameworks (e.g. Hadoop) where the overhead of creating many threads is significant.

Constructor Summary

CollectorStreamBase()

Method Summary

void	base(String base) base declaration seen
void	finish() Finish parsing
String	getBaseIri()
abstract Collection<T>	getCollected()
PrefixMap	getPrefixes()
void	prefix(String prefix, String iri) prefix declaration seen
void	quad(Quad quad) Quad emitted
void	start() Start parsing
void	triple(Triple triple) Triple emitted
void	tuple(Tuple<Node> tuple) Generalized emitted

Methods inherited from class java.lang.Object

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

Constructor Detail

CollectorStreamBase

public CollectorStreamBase()

Method Detail

finish

public void finish()

Description copied from interface: StreamRDF

Finish parsing

Specified by:

finish in interface StreamRDF

triple

public void triple(Triple triple)

Description copied from interface: StreamRDF

Triple emitted

Specified by:

triple in interface StreamRDF

tuple

public void tuple(Tuple<Node> tuple)

Description copied from interface: StreamRDF

Generalized emitted

Specified by:

tuple in interface StreamRDF

quad

public void quad(Quad quad)

Description copied from interface: StreamRDF

Quad emitted

Specified by:

quad in interface StreamRDF

start

public void start()

Description copied from interface: StreamRDF

Start parsing

Specified by:

start in interface StreamRDF

base

public void base(String base)

Description copied from interface: StreamRDF

base declaration seen

Specified by:

base in interface StreamRDF

prefix

public void prefix(String prefix,
                   String iri)

Description copied from interface: StreamRDF

prefix declaration seen

Specified by:

prefix in interface StreamRDF

getPrefixes

public PrefixMap getPrefixes()

getBaseIri

public String getBaseIri()

getCollected

public abstract Collection<T> getCollected()

Returns:

The collection received by this instance.