public class CollectorStreamRDF extends Object implements StreamRDF
Collection
.
The resulting collection can be retrieved via the
getTriples()
and getQuads()
methods.
The 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 for a push-pull parser setup is significant.Constructor and Description |
---|
CollectorStreamRDF() |
Modifier and Type | Method and Description |
---|---|
void |
base(String base)
base declaration seen
|
void |
finish()
Finish processing
|
String |
getBaseIri() |
PrefixMap |
getPrefixes() |
List<Quad> |
getQuads() |
List<Triple> |
getTriples() |
void |
prefix(String prefix,
String iri)
prefix declaration seen
|
void |
quad(Quad quad)
Quad emitted
|
void |
start()
Start processing
|
void |
triple(Triple triple)
Triple emitted
|
public void start()
StreamRDF
public void finish()
StreamRDF
public void triple(Triple triple)
StreamRDF
public void base(String base)
StreamRDF
public void prefix(String prefix, String iri)
StreamRDF
public PrefixMap getPrefixes()
public String getBaseIri()
Licenced under the Apache License, Version 2.0