com.bigdata.rdf.lexicon

Class Id2TermWriteProc

java.lang.Object

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

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

com.bigdata.rdf.lexicon.Id2TermWriteProc

All Implemented Interfaces:

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

public class Id2TermWriteProc
extends AbstractKeyArrayIndexProcedure<Void>
implements IParallelizableIndexProcedure<Void>, IMutableRelationIndexWriteProcedure<Void>

Unisolated write operation makes consistent assertions on the id:term index based on the data developed by the Term2IdWriteProc operation.

Author:

Bryan Thompson

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Id2TermWriteProc.Id2TermWriteProcConstructor

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

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

Constructor Summary

Constructors

Modifier	Constructor and Description
	Id2TermWriteProc() De-serialization constructor.
protected	Id2TermWriteProc(IRabaCoder keysCoder, IRabaCoder valsCoder, int fromIndex, int toIndex, byte[][] keys, byte[][] vals)

Method Summary

Methods

Modifier and Type	Method and Description
Void	applyOnce(IIndex ndx, IRaba keys, IRaba vals) Conditionally inserts each key-value pair into the index.
boolean	isReadOnly() Return true iff the procedure asserts that it will not write on the index.
protected IResultHandler<Void,Void>	newAggregator() Nothing is returned, so nothing to aggregate, but uses a NopAggregator to preserve striping against a local index.

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

Id2TermWriteProc

public Id2TermWriteProc()

De-serialization constructor.

Id2TermWriteProc

protected Id2TermWriteProc(IRabaCoder keysCoder,
                IRabaCoder valsCoder,
                int fromIndex,
                int toIndex,
                byte[][] keys,
                byte[][] vals)

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 Void applyOnce(IIndex ndx,
             IRaba keys,
             IRaba vals)

Conditionally inserts each key-value pair into the index. The keys are the term identifiers. The values are the terms as serialized by BigdataValueSerializer. Since a conditional insert is used, the operation does not cause terms that are already known to the ids index to be re-inserted, thereby reducing writes of dirty index nodes.

Specified by:

applyOnce in class AbstractKeyArrayIndexProcedure<Void>

Parameters:

ndx - The index.

Returns:

null.

newAggregator

protected IResultHandler<Void,Void> newAggregator()

Nothing is returned, so nothing to aggregate, but uses a NopAggregator to preserve striping against a local index.

Specified by:

newAggregator in class AbstractKeyArrayIndexProcedure<Void>

Returns:

The IResultHandler -or- null

See Also:

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