public abstract class PersistingRdfStreamConsumer extends Object implements RdfStreamConsumer
Modifier and Type | Field and Description |
---|---|
protected Predicate<com.hp.hpl.jena.graph.Triple> |
isFedoraSubjectTriple |
Constructor and Description |
---|
PersistingRdfStreamConsumer(IdentifierConverter<com.hp.hpl.jena.rdf.model.Resource,FedoraResource> idTranslator,
javax.jcr.Session session,
RdfStream stream)
Ordinary constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
consume()
Synchronous consumption.
|
com.google.common.util.concurrent.ListenableFuture<Boolean> |
consumeAsync()
Asynchronous consumption.
|
JcrRdfTools |
jcrRdfTools() |
protected abstract void |
operateOnMixin(com.hp.hpl.jena.rdf.model.Resource mixinResource,
FedoraResource subjectNode) |
protected abstract void |
operateOnProperty(com.hp.hpl.jena.rdf.model.Statement t,
FedoraResource subjectNode) |
protected void |
operateOnTriple(com.hp.hpl.jena.rdf.model.Statement input) |
RdfStream |
stream() |
IdentifierConverter<com.hp.hpl.jena.rdf.model.Resource,FedoraResource> |
translator() |
protected final Predicate<com.hp.hpl.jena.graph.Triple> isFedoraSubjectTriple
public PersistingRdfStreamConsumer(IdentifierConverter<com.hp.hpl.jena.rdf.model.Resource,FedoraResource> idTranslator, javax.jcr.Session session, RdfStream stream)
idTranslator
- the id translatorsession
- the sessionstream
- the rdf streampublic void consume() throws MalformedRdfException
IteratorConsumer
consume
in interface IteratorConsumer<com.hp.hpl.jena.graph.Triple,Boolean>
MalformedRdfException
- if malformed rdf exception occurredprotected void operateOnTriple(com.hp.hpl.jena.rdf.model.Statement input) throws MalformedRdfException
MalformedRdfException
protected abstract void operateOnProperty(com.hp.hpl.jena.rdf.model.Statement t, FedoraResource subjectNode) throws javax.jcr.RepositoryException
javax.jcr.RepositoryException
protected abstract void operateOnMixin(com.hp.hpl.jena.rdf.model.Resource mixinResource, FedoraResource subjectNode) throws javax.jcr.RepositoryException
javax.jcr.RepositoryException
public com.google.common.util.concurrent.ListenableFuture<Boolean> consumeAsync()
IteratorConsumer
consumeAsync
in interface IteratorConsumer<com.hp.hpl.jena.graph.Triple,Boolean>
public IdentifierConverter<com.hp.hpl.jena.rdf.model.Resource,FedoraResource> translator()
public JcrRdfTools jcrRdfTools()
Copyright © 2013–2016 DuraSpace, Inc.. All rights reserved.