eu.larkc.core.query
Class GraphResultBase

java.lang.Object
  eu.larkc.core.query.GraphResultBase

All Implemented Interfaces:

InformationSet, SetOfStatements, java.io.Serializable

Direct Known Subclasses:

ORDIGraphResult, RDFXMLGraphResult

public abstract class GraphResultBase
extends java.lang.Object
implements SetOfStatements

GraphResultBase is an abstract class to implement asynchronous streaming of RDF statements. All implementing classes must: 1. Put the next statements from the stream with results.put(X) 2. For the final statement to put results.put(new FinalStatement())

Author:

vassil

See Also:

Serialized Form

Nested Class Summary

class	GraphResultBase.BlockingQueueIterator Helper class to iterate the blocking queue used to simulate asynchrnous streaming of RDF statements.
class	GraphResultBase.FinalStatement Helper class to denote the end of streamed statements.

Constructor Summary

GraphResultBase()

Method Summary

void	close()
CloseableIterator<org.openrdf.model.Statement>	getStatements() Iterates the statements.

Methods inherited from class java.lang.Object

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

Methods inherited from interface eu.larkc.core.data.InformationSet

toRDF

Constructor Detail

GraphResultBase

public GraphResultBase()

Method Detail

close

public void close()

getStatements

public CloseableIterator<org.openrdf.model.Statement> getStatements()

Description copied from interface: SetOfStatements

Iterates the statements.

Specified by:

getStatements in interface SetOfStatements

Returns:

closeableiterator over the statements.s