Package org.eclipse.rdf4j.rio.helpers
Class TimeLimitRDFHandler
- java.lang.Object
-
- org.eclipse.rdf4j.rio.helpers.RDFHandlerWrapper
-
- org.eclipse.rdf4j.rio.helpers.TimeLimitRDFHandler
-
- All Implemented Interfaces:
RDFHandler
public class TimeLimitRDFHandler extends RDFHandlerWrapper
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private static class
TimeLimitRDFHandler.InterruptTask
-
Field Summary
Fields Modifier and Type Field Description private java.util.concurrent.atomic.AtomicBoolean
ended
private TimeLimitRDFHandler.InterruptTask
interruptTask
private boolean
isInterrupted
private org.slf4j.Logger
logger
private static java.util.Timer
timer
-
Constructor Summary
Constructors Constructor Description TimeLimitRDFHandler(RDFHandler rdfHandler, long timeLimit)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private void
checkInterrupted()
void
endRDF()
Signals the end of the RDF data.void
handleComment(java.lang.String comment)
Handles a comment.void
handleNamespace(java.lang.String prefix, java.lang.String uri)
Handles a namespace declaration/definition.void
handleStatement(Statement st)
Handles a statement.private void
interrupt()
private boolean
isEnded()
void
startRDF()
Signals the start of the RDF data.-
Methods inherited from class org.eclipse.rdf4j.rio.helpers.RDFHandlerWrapper
getModelFactory
-
-
-
-
Field Detail
-
timer
private static final java.util.Timer timer
-
logger
private final org.slf4j.Logger logger
-
interruptTask
private final TimeLimitRDFHandler.InterruptTask interruptTask
-
isInterrupted
private volatile boolean isInterrupted
-
ended
private final java.util.concurrent.atomic.AtomicBoolean ended
-
-
Constructor Detail
-
TimeLimitRDFHandler
public TimeLimitRDFHandler(RDFHandler rdfHandler, long timeLimit)
-
-
Method Detail
-
isEnded
private boolean isEnded()
-
startRDF
public void startRDF() throws RDFHandlerException
Description copied from interface:RDFHandler
Signals the start of the RDF data. This method is called before any data is reported.- Specified by:
startRDF
in interfaceRDFHandler
- Overrides:
startRDF
in classRDFHandlerWrapper
- Throws:
RDFHandlerException
- If the RDF handler has encountered an unrecoverable error.
-
endRDF
public void endRDF() throws RDFHandlerException
Description copied from interface:RDFHandler
Signals the end of the RDF data. This method is called when all data has been reported.- Specified by:
endRDF
in interfaceRDFHandler
- Overrides:
endRDF
in classRDFHandlerWrapper
- Throws:
RDFHandlerException
- If the RDF handler has encountered an unrecoverable error.
-
handleNamespace
public void handleNamespace(java.lang.String prefix, java.lang.String uri) throws RDFHandlerException
Description copied from interface:RDFHandler
Handles a namespace declaration/definition. A namespace declaration associates a (short) prefix string with the namespace's URI. The prefix for default namespaces, which do not have an associated prefix, are represented as empty strings.- Specified by:
handleNamespace
in interfaceRDFHandler
- Overrides:
handleNamespace
in classRDFHandlerWrapper
- Parameters:
prefix
- The prefix for the namespace, or an empty string in case of a default namespace.uri
- The URI that the prefix maps to.- Throws:
RDFHandlerException
- If the RDF handler has encountered an unrecoverable error.
-
handleStatement
public void handleStatement(Statement st) throws RDFHandlerException
Description copied from interface:RDFHandler
Handles a statement.- Specified by:
handleStatement
in interfaceRDFHandler
- Overrides:
handleStatement
in classRDFHandlerWrapper
- Parameters:
st
- The statement.- Throws:
RDFHandlerException
- If the RDF handler has encountered an unrecoverable error.
-
handleComment
public void handleComment(java.lang.String comment) throws RDFHandlerException
Description copied from interface:RDFHandler
Handles a comment.- Specified by:
handleComment
in interfaceRDFHandler
- Overrides:
handleComment
in classRDFHandlerWrapper
- Parameters:
comment
- The comment.- Throws:
RDFHandlerException
- If the RDF handler has encountered an unrecoverable error.
-
checkInterrupted
private void checkInterrupted() throws RDFHandlerException
- Throws:
RDFHandlerException
-
interrupt
private void interrupt()
-
-