com.bigdata.rdf.rules

Class RDFJoinNexus.InsertSPOAndJustificationBuffer<E>

java.lang.Object

com.bigdata.relation.accesspath.AbstractArrayBuffer<ISolution<R>[]>

com.bigdata.relation.rule.eval.AbstractSolutionBuffer<E>

com.bigdata.rdf.rules.RDFJoinNexus.InsertSPOAndJustificationBuffer<E>

Type Parameters:

E -

All Implemented Interfaces:

IBuffer<ISolution<E>[]>

Enclosing class:

RDFJoinNexus

public static class RDFJoinNexus.InsertSPOAndJustificationBuffer<E>
extends AbstractSolutionBuffer<E>

Buffer writes on IMutableRelation#insert(IChunkedIterator) when it is flushed.

Version:

$Id$

Author:

Bryan Thompson

Nested Class Summary

Nested classes/interfaces inherited from class com.bigdata.relation.rule.eval.AbstractSolutionBuffer

AbstractSolutionBuffer.DeleteSolutionBuffer<E>, AbstractSolutionBuffer.InsertSolutionBuffer<E>

Field Summary

Fields inherited from class com.bigdata.relation.accesspath.AbstractArrayBuffer

buffer, capacity, cls, filter, size

Constructor Summary

Constructors

Constructor and Description
RDFJoinNexus.InsertSPOAndJustificationBuffer(int capacity, IMutableRelation<E> relation)

Method Summary

Methods

Modifier and Type	Method and Description
protected long	flush(IChunkedOrderedIterator<ISolution<E>> itr) Concrete implementations must process the ISolutions, causing the appropriate mutation on the target IRelation.

Methods inherited from class com.bigdata.relation.rule.eval.AbstractSolutionBuffer

flush, getRelation

Methods inherited from class com.bigdata.relation.accesspath.AbstractArrayBuffer

accept, add, flush, isEmpty, reset, size

Methods inherited from class java.lang.Object

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

Constructor Detail

RDFJoinNexus.InsertSPOAndJustificationBuffer

public RDFJoinNexus.InsertSPOAndJustificationBuffer(int capacity,
                                            IMutableRelation<E> relation)

Parameters:

capacity -

relation -

Method Detail

flush

protected long flush(IChunkedOrderedIterator<ISolution<E>> itr)

Description copied from class: AbstractSolutionBuffer

Concrete implementations must process the ISolutions, causing the appropriate mutation on the target IRelation.

Note: The ISolutions generally appear in an arbitrary order. They can either be resolved to IRelation elements or be sorted into ordered ISolution chunks using a SolutionComparator.

Specified by:

flush in class AbstractSolutionBuffer<E>

Parameters:

itr - The iterator (the order of the elements is unknown).

Returns:

The #of elements that were modified in the backing relation when the buffer was flushed