com.bigdata.rdf.spo
Class JustificationRemover

java.lang.Object
  com.bigdata.rdf.spo.JustificationRemover

All Implemented Interfaces:

Callable<Long>

public class JustificationRemover
extends Object
implements Callable<Long>

Class writes on the justification index, removing all Justifications for each statement specified by the caller.

Note: There is only one index for Justifications. The keys all use the {s,p,o} of the entailed statement as their prefix, so given a statement it is trivial to do a range scan for its justifications.

Version:

$Id: JustificationRemover.java 2265 2009-10-26 12:51:06Z thompsonbry $

Author:

Bryan Thompson

TODO:

Since this task accepts a "chunk" of statements, it should flood range delete requests for each of the statements to the justifications index using the ExecutorService , but only if the triple store provides concurrency control for writers on the same index.

Field Summary

protected static boolean	DEBUG True iff the log level is DEBUG or less.
protected static boolean	INFO True iff the log level is INFO or less.
protected static org.apache.log4j.Logger	log

Constructor Summary

JustificationRemover(SPORelation db, ISPO[] stmts, int numStmts, boolean clone, AtomicLong sortTime, AtomicLong writeTime)

Method Summary

Long

call()

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final org.apache.log4j.Logger log

INFO

protected static final boolean INFO

True iff the log level is INFO or less.

DEBUG

protected static final boolean DEBUG

True iff the log level is DEBUG or less.

Constructor Detail

JustificationRemover

public JustificationRemover(SPORelation db,
                            ISPO[] stmts,
                            int numStmts,
                            boolean clone,
                            AtomicLong sortTime,
                            AtomicLong writeTime)

Method Detail

call

public Long call()
          throws Exception

Specified by:

call in interface Callable<Long>

Throws:

Exception