com.bigdata.rdf.lexicon

Class BlobsWriteProc

java.lang.Object

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

com.bigdata.btree.proc.AbstractKeyArrayIndexProcedure<BlobsWriteProc.Result>

com.bigdata.rdf.lexicon.BlobsWriteProc

All Implemented Interfaces:

IIndexProcedure<BlobsWriteProc.Result>, IKeyArrayIndexProcedure<BlobsWriteProc.Result>, IParallelizableIndexProcedure<BlobsWriteProc.Result>, IReadOnly, IMutableRelationIndexWriteProcedure<BlobsWriteProc.Result>, Externalizable, Serializable

public class BlobsWriteProc
extends AbstractKeyArrayIndexProcedure<BlobsWriteProc.Result>
implements IParallelizableIndexProcedure<BlobsWriteProc.Result>, IMutableRelationIndexWriteProcedure<BlobsWriteProc.Result>

This unisolated operation inserts Values into the {termCode,hash(Value),counter}:Value index, assigning IVs to Values as a side-effect.

Note that it is perfectly possible that a concurrent client will overlap in the terms being inserted. The results will always be fully consistent if the rules of the road are observed since (a) unisolated operations are single-threaded; and (b) IVs are assigned in an unisolated atomic operation by BlobsWriteProc.

Author:

Bryan Thompson

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BlobsWriteProc.BlobsWriteProcConstructor
static class	BlobsWriteProc.Result Object encapsulates the discovered / assigned IVs and provides efficient serialization for communication of those data to the client.

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
	BlobsWriteProc() De-serialization constructor.
protected	BlobsWriteProc(IRabaCoder keySer, IRabaCoder valSer, int fromIndex, int toIndex, byte[][] keys, byte[][] vals, boolean readOnly, boolean storeBlankNodes)

Method Summary

Methods

Modifier and Type	Method and Description
BlobsWriteProc.Result	applyOnce(IIndex ndx, IRaba keys, IRaba vals) For each term whose serialized key is mapped to the current index partition, lookup the term in the terms index.
boolean	isReadOnly() Return true iff the procedure asserts that it will not write on the index.
boolean	isToldBNodes()
protected IResultHandler<BlobsWriteProc.Result,BlobsWriteProc.Result>	newAggregator() Split-wise aggregation followed by combining the results across those splits in order to return an aggregated result whose counters[] is 1:1 with the original keys[][].
protected void	readMetadata(ObjectInput in) Reads metadata written by AbstractKeyArrayIndexProcedure.writeMetadata(ObjectOutput).
protected void	writeMetadata(ObjectOutput out) Writes metadata (not the keys or values, but just other metadata used by the procedure).

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

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

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

BlobsWriteProc

public BlobsWriteProc()

De-serialization constructor.

BlobsWriteProc

protected BlobsWriteProc(IRabaCoder keySer,
              IRabaCoder valSer,
              int fromIndex,
              int toIndex,
              byte[][] keys,
              byte[][] vals,
              boolean readOnly,
              boolean storeBlankNodes)

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

isToldBNodes

public final boolean isToldBNodes()

applyOnce

public BlobsWriteProc.Result applyOnce(IIndex ndx,
                              IRaba keys,
                              IRaba vals)

For each term whose serialized key is mapped to the current index partition, lookup the term in the terms index. If it is there then wrap its key as its IV. Otherwise, note the of terms in the collision bucket, and insert {hash(term),counter},term} entry into the terms index.

Specified by:

applyOnce in class AbstractKeyArrayIndexProcedure<BlobsWriteProc.Result>

Parameters:

ndx - The terms index.

Returns:

The BlobsWriteProc.Result, which contains the discovered / assigned term identifiers. TODO There is no point sending bnodes when readOnly and NOT in told bnodes mode because the caller is unable to unify a blank node with an entry in the index.

readMetadata

protected void readMetadata(ObjectInput in)
                     throws IOException,
                            ClassNotFoundException

Description copied from class: AbstractKeyArrayIndexProcedure

Reads metadata written by AbstractKeyArrayIndexProcedure.writeMetadata(ObjectOutput).

Overrides:

readMetadata in class AbstractKeyArrayIndexProcedure<BlobsWriteProc.Result>

Throws:

IOException

ClassNotFoundException

writeMetadata

protected void writeMetadata(ObjectOutput out)
                      throws IOException

Writes metadata (not the keys or values, but just other metadata used by the procedure).

The default implementation writes toIndex - fromIndex, which is the #of keys.

Overrides:

writeMetadata in class AbstractKeyArrayIndexProcedure<BlobsWriteProc.Result>

Parameters:

out -

Throws:

IOException

newAggregator

protected IResultHandler<BlobsWriteProc.Result,BlobsWriteProc.Result> newAggregator()

Split-wise aggregation followed by combining the results across those splits in order to return an aggregated result whose counters[] is 1:1 with the original keys[][].

Specified by:

newAggregator in class AbstractKeyArrayIndexProcedure<BlobsWriteProc.Result>

Returns:

The IResultHandler -or- null

See Also:

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