org.dice_research.squirrel.sink.impl.sparql

Class AbstractBufferingSink

java.lang.Object

org.dice_research.squirrel.sink.impl.sparql.AbstractBufferingSink

All Implemented Interfaces:

org.dice_research.squirrel.sink.quadbased.QuadBasedSink, org.dice_research.squirrel.sink.SinkBase, org.dice_research.squirrel.sink.triplebased.TripleBasedSink

Direct Known Subclasses:

SparqlBasedSink, TDBSink

public abstract class AbstractBufferingSink
extends Object
implements org.dice_research.squirrel.sink.triplebased.TripleBasedSink, org.dice_research.squirrel.sink.quadbased.QuadBasedSink

An abstract implementation for TripleBasedSinks and QuadBasedSinks

Author:

gsjunior gsjunior@mail.uni-paderborn.de

Field Summary

Fields

Modifier and Type	Field and Description
protected int	bufferSize
protected static int	DEFAULT_BUFFER_SIZE Interval that specifies how many triples are to be buffered at once until they are sent to the sink.
private static org.slf4j.Logger	LOGGER
private Map<org.dice_research.squirrel.data.uri.CrawleableUri,QuadBuffer>	quadBuffer
private Map<org.dice_research.squirrel.data.uri.CrawleableUri,TripleBuffer>	tripleBuffer The data structure (map) in which the triples are buffered.

Constructor Summary

Constructors

Constructor and Description
AbstractBufferingSink()

Method Summary

Modifier and Type	Method and Description
void	addQuad(org.dice_research.squirrel.data.uri.CrawleableUri uri, org.apache.jena.sparql.core.Quad quad)
void	addTriple(org.dice_research.squirrel.data.uri.CrawleableUri uri, org.apache.jena.graph.Triple triple)
void	closeSinkForUri(org.dice_research.squirrel.data.uri.CrawleableUri uri)
void	openSinkForUri(org.dice_research.squirrel.data.uri.CrawleableUri uri)
protected abstract void	sendQuads(org.dice_research.squirrel.data.uri.CrawleableUri uri, Collection<org.apache.jena.sparql.core.Quad> buffer)
protected abstract void	sendTriples(org.dice_research.squirrel.data.uri.CrawleableUri uri, Collection<org.apache.jena.graph.Triple> buffer)

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

private static final org.slf4j.Logger LOGGER

DEFAULT_BUFFER_SIZE

protected static final int DEFAULT_BUFFER_SIZE

Interval that specifies how many triples are to be buffered at once until they are sent to the sink.

See Also:

Constant Field Values

tripleBuffer

private Map<org.dice_research.squirrel.data.uri.CrawleableUri,TripleBuffer> tripleBuffer

The data structure (map) in which the triples are buffered.

quadBuffer

private Map<org.dice_research.squirrel.data.uri.CrawleableUri,QuadBuffer> quadBuffer

bufferSize

protected int bufferSize

Constructor Detail

AbstractBufferingSink

public AbstractBufferingSink()

Method Detail

openSinkForUri

public void openSinkForUri(org.dice_research.squirrel.data.uri.CrawleableUri uri)

Specified by:

openSinkForUri in interface org.dice_research.squirrel.sink.SinkBase

addTriple

public void addTriple(org.dice_research.squirrel.data.uri.CrawleableUri uri,
                      org.apache.jena.graph.Triple triple)

Specified by:

addTriple in interface org.dice_research.squirrel.sink.triplebased.TripleBasedSink

addQuad

public void addQuad(org.dice_research.squirrel.data.uri.CrawleableUri uri,
                    org.apache.jena.sparql.core.Quad quad)

Specified by:

addQuad in interface org.dice_research.squirrel.sink.quadbased.QuadBasedSink

sendTriples

protected abstract void sendTriples(org.dice_research.squirrel.data.uri.CrawleableUri uri,
                                    Collection<org.apache.jena.graph.Triple> buffer)

sendQuads

protected abstract void sendQuads(org.dice_research.squirrel.data.uri.CrawleableUri uri,
                                  Collection<org.apache.jena.sparql.core.Quad> buffer)

closeSinkForUri

public void closeSinkForUri(org.dice_research.squirrel.data.uri.CrawleableUri uri)

Specified by:

closeSinkForUri in interface org.dice_research.squirrel.sink.SinkBase