org.fcrepo.kernel.impl.utils.iterators

Class PersistingRdfStreamConsumer

java.lang.Object

org.fcrepo.kernel.impl.utils.iterators.PersistingRdfStreamConsumer

All Implemented Interfaces:

IteratorConsumer<com.hp.hpl.jena.graph.Triple,Boolean>, RdfStreamConsumer

Direct Known Subclasses:

RdfAdder, RdfRemover

public abstract class PersistingRdfStreamConsumer
extends Object
implements RdfStreamConsumer

Since:

Oct 24, 2013

Author:

ajs6f

Field Summary

Fields

Modifier and Type	Field and Description
protected com.google.common.base.Predicate<com.hp.hpl.jena.graph.Triple>	isFedoraSubjectTriple

Constructor Summary

Constructors

Constructor and Description
PersistingRdfStreamConsumer(IdentifierConverter<com.hp.hpl.jena.rdf.model.Resource,FedoraResource> idTranslator, javax.jcr.Session session, RdfStream stream) Ordinary constructor.

Method Summary

Methods

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()

Methods inherited from class java.lang.Object

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

Field Detail

isFedoraSubjectTriple

protected final com.google.common.base.Predicate<com.hp.hpl.jena.graph.Triple> isFedoraSubjectTriple

Constructor Detail

PersistingRdfStreamConsumer

public PersistingRdfStreamConsumer(IdentifierConverter<com.hp.hpl.jena.rdf.model.Resource,FedoraResource> idTranslator,
                           javax.jcr.Session session,
                           RdfStream stream)

Ordinary constructor.

Parameters:

idTranslator -

session -

stream -

Method Detail

consume

public void consume()
             throws MalformedRdfException

Description copied from interface: IteratorConsumer

Synchronous consumption.

Specified by:

consume in interface IteratorConsumer<com.hp.hpl.jena.graph.Triple,Boolean>

Throws:

MalformedRdfException

operateOnTriple

protected void operateOnTriple(com.hp.hpl.jena.rdf.model.Statement input)
                        throws MalformedRdfException

Throws:

MalformedRdfException

operateOnProperty

protected abstract void operateOnProperty(com.hp.hpl.jena.rdf.model.Statement t,
                     FedoraResource subjectNode)
                                   throws javax.jcr.RepositoryException

Throws:

javax.jcr.RepositoryException

operateOnMixin

protected abstract void operateOnMixin(com.hp.hpl.jena.rdf.model.Resource mixinResource,
                  FedoraResource subjectNode)
                                throws javax.jcr.RepositoryException

Throws:

javax.jcr.RepositoryException

consumeAsync

public com.google.common.util.concurrent.ListenableFuture<Boolean> consumeAsync()

Description copied from interface: IteratorConsumer

Asynchronous consumption.

Specified by:

consumeAsync in interface IteratorConsumer<com.hp.hpl.jena.graph.Triple,Boolean>

Returns:

ListenableFuture

stream

public RdfStream stream()

Returns:

the stream

translator

public IdentifierConverter<com.hp.hpl.jena.rdf.model.Resource,FedoraResource> translator()

Returns:

the idTranslator

jcrRdfTools

public JcrRdfTools jcrRdfTools()

Returns:

the jcrRdfTools