T
- Type of the value stored in the collectionpublic abstract class CollectorStreamBase<T> extends Object implements StreamRDF
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 and Description |
---|
CollectorStreamBase() |
Modifier and Type | Method and Description |
---|---|
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
|
public void finish()
StreamRDF
public void triple(Triple triple)
StreamRDF
public void tuple(Tuple<Node> tuple)
StreamRDF
public void start()
StreamRDF
public void base(String base)
StreamRDF
public void prefix(String prefix, String iri)
StreamRDF
public PrefixMap getPrefixes()
public String getBaseIri()
public abstract Collection<T> getCollected()
Licenced under the Apache License, Version 2.0