com.bigdata.rdf.spo
Class BulkFilterConverter

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

All Implemented Interfaces:

IChunkConverter<ISPO,ISPO>

public class BulkFilterConverter
extends Object
implements IChunkConverter<ISPO,ISPO>

Bulk filters for ISPOs either present or NOT present in the target statement IIndex.

Version:

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

Author:

Bryan Thompson

Constructor Summary

BulkFilterConverter(IIndex ndx, boolean present)

Method Summary

ISPO[]

convert(IChunkedOrderedIterator<ISPO> src) Convert the next chunk of element(s) from the source iterator into target element(s).

Methods inherited from class java.lang.Object

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

Constructor Detail

BulkFilterConverter

public BulkFilterConverter(IIndex ndx,
                           boolean present)

Parameters:

ndx - The SPO index.

present - true if true, filter for statements that exist in the db, otherwise filter for statements that do not exist

Method Detail

convert

public ISPO[] convert(IChunkedOrderedIterator<ISPO> src)

Description copied from interface: IChunkConverter

Convert the next chunk of element(s) from the source iterator into target element(s).

Note: This method will only be invoked if ChunkedConvertingIterator.hasNext() reports true for the source iterator.

Note: Iterators are single-threaded so the implementation of this method does not need to be thread-safe.

Specified by:

convert in interface IChunkConverter<ISPO,ISPO>

Parameters:

src - The source iterator.

Returns:

The target chunk (not null, but may be empty).