com.bigdata.rdf.sail

Class SPARQLUpdateEvent.LoadProgress

java.lang.Object

com.bigdata.rdf.sail.SPARQLUpdateEvent

com.bigdata.rdf.sail.SPARQLUpdateEvent.LoadProgress

Enclosing class:

SPARQLUpdateEvent

public static class SPARQLUpdateEvent.LoadProgress
extends SPARQLUpdateEvent

Incremental progress report during LOAD.

Nested Class Summary

Nested classes/interfaces inherited from class com.bigdata.rdf.sail.SPARQLUpdateEvent

SPARQLUpdateEvent.DeleteInsertWhereStats, SPARQLUpdateEvent.LoadProgress

Constructor Summary

Constructors

Constructor and Description
SPARQLUpdateEvent.LoadProgress(Update op, long elapsed, long nparsed, boolean done)

Method Summary

Methods

Modifier and Type	Method and Description
long	getParsedCount() Return the #of statements parsed as of the moment that this event was generated.
boolean	isDone() Return true iff the LOAD operation has finished parsing the document.
long	triplesPerSecond() Report the parser rate in triples per second.

Methods inherited from class com.bigdata.rdf.sail.SPARQLUpdateEvent

getBatchResolveNanos, getCause, getConnectionFlushNanos, getDeleteInsertWhereStats, getElapsedNanos, getUpdate

Methods inherited from class java.lang.Object

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

Constructor Detail

SPARQLUpdateEvent.LoadProgress

public SPARQLUpdateEvent.LoadProgress(Update op,
                              long elapsed,
                              long nparsed,
                              boolean done)

Method Detail

getParsedCount

public long getParsedCount()

Return the #of statements parsed as of the moment that this event was generated.

Note: Statements are incrementally written onto the backing store. Thus, the parser will often run ahead of the actual index writes. This can manifest as periods during which the "parsed" statement count climbs quickly followed by periods in which it is stable. That occurs when the parser is blocked because it can not add statements to the connection while the connection is being flushed to the database. There is a ticket to fix this blocking behavior so the parser can continue to run while we are flushing statements onto the database - see below.

See Also:

Improve load performance

isDone

public boolean isDone()

Return true iff the LOAD operation has finished parsing the document.

Note: This does not mean that the statements have been written through to the disk, just that the parsed is done running.

triplesPerSecond

public long triplesPerSecond()

Report the parser rate in triples per second.