com.bigdata.rdf.spo

Class JustIndexWriteProc

java.lang.Object

com.bigdata.btree.proc.AbstractIndexProcedure<T>

com.bigdata.btree.proc.AbstractKeyArrayIndexProcedure<Long>

com.bigdata.rdf.spo.JustIndexWriteProc

All Implemented Interfaces:

IIndexProcedure<Long>, IKeyArrayIndexProcedure<Long>, IParallelizableIndexProcedure<Long>, IReadOnly, IMutableRelationIndexWriteProcedure<Long>, Externalizable, Serializable

public class JustIndexWriteProc
extends AbstractKeyArrayIndexProcedure<Long>
implements IParallelizableIndexProcedure<Long>, IMutableRelationIndexWriteProcedure<Long>

Procedure for writing Justifications on an index or index partition.

Author:

Bryan Thompson

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JustIndexWriteProc.WriteJustificationsProcConstructor

Nested classes/interfaces inherited from class com.bigdata.btree.proc.AbstractKeyArrayIndexProcedure

AbstractKeyArrayIndexProcedure.ResultBitBuffer, AbstractKeyArrayIndexProcedure.ResultBitBufferCounter, AbstractKeyArrayIndexProcedure.ResultBitBufferHandler, AbstractKeyArrayIndexProcedure.ResultBuffer, AbstractKeyArrayIndexProcedure.ResultBufferHandler

Constructor Summary

Constructors

Constructor and Description
JustIndexWriteProc() De-serialization constructor.
JustIndexWriteProc(IRabaCoder keySer, int fromIndex, int toIndex, byte[][] keys)

Method Summary

Methods

Modifier and Type	Method and Description
Long	applyOnce(IIndex ndx, IRaba keys, IRaba vals) Apply the procedure to the specified key range of the index.
boolean	isReadOnly() Return true iff the procedure asserts that it will not write on the index.
protected IResultHandler<Long,Long>	newAggregator() Uses LongAggregator to combine the mutation counts.

Methods inherited from class com.bigdata.btree.proc.AbstractKeyArrayIndexProcedure

apply, getKeys, getKeysCoder, getValues, getValuesCoder, readExternal, readMetadata, writeExternal, writeMetadata

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.bigdata.btree.proc.IIndexProcedure

apply

Constructor Detail

JustIndexWriteProc

public JustIndexWriteProc()

De-serialization constructor.

JustIndexWriteProc

public JustIndexWriteProc(IRabaCoder keySer,
                  int fromIndex,
                  int toIndex,
                  byte[][] keys)

Method Detail

isReadOnly

public final boolean isReadOnly()

Description copied from interface: IReadOnly

Return true iff the procedure asserts that it will not write on the index. When true, the procedure may be run against a view of the index that is read-only or which allows concurrent processes to read on the same index object. When false the procedure will be run against a mutable view of the index (assuming that the procedure is executed in a context that has access to a mutable index view).

Specified by:

isReadOnly in interface IReadOnly

applyOnce

public Long applyOnce(IIndex ndx,
             IRaba keys,
             IRaba vals)

Description copied from class: AbstractKeyArrayIndexProcedure

Apply the procedure to the specified key range of the index.

Specified by:

applyOnce in class AbstractKeyArrayIndexProcedure<Long>

Parameters:

ndx - The index.

Returns:

The #of justifications actually written on the index as a Long.

newAggregator

protected IResultHandler<Long,Long> newAggregator()

Uses LongAggregator to combine the mutation counts.

Specified by:

newAggregator in class AbstractKeyArrayIndexProcedure<Long>

Returns:

The IResultHandler -or- null

See Also:

NopAggregator, IParallelizableIndexProcedure, (Schedule more IOs when loading data)