com.bigdata.relation.accesspath

Class UnsyncLocalOutputBuffer<E extends IBindingSet>

java.lang.Object

com.bigdata.relation.accesspath.AbstractUnsynchronizedArrayBuffer<E>

com.bigdata.relation.accesspath.UnsyncLocalOutputBuffer<E>

Type Parameters:

E -

All Implemented Interfaces:

IBuffer<E>

public class UnsyncLocalOutputBuffer<E extends IBindingSet>
extends AbstractUnsynchronizedArrayBuffer<E>

Wraps the base class to update the caller's BOpStats.

Version:

$Id: UnsyncLocalOutputBuffer.java 3448 2010-08-18 20:55:58Z thompsonbry $

Author:

Bryan Thompson

Constructor Summary

Constructors

Constructor and Description
UnsyncLocalOutputBuffer(int capacity, IBlockingBuffer<E[]> syncBuffer)
UnsyncLocalOutputBuffer(int capacity, IBlockingBuffer<E[]> syncBuffer, IElementFilter<E> filter)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	handleChunk(E[] chunk) Adds the chunk to the syncBuffer and updates the BOpStats.

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

accept, add, add2, flush, isEmpty, overflow, reset, size

Methods inherited from class java.lang.Object

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

Constructor Detail

UnsyncLocalOutputBuffer

public UnsyncLocalOutputBuffer(int capacity,
                       IBlockingBuffer<E[]> syncBuffer)

Parameters:

capacity - The capacity of this buffer.

syncBuffer - The thread-safe buffer onto which this buffer writes when it overflows.

UnsyncLocalOutputBuffer

public UnsyncLocalOutputBuffer(int capacity,
                       IBlockingBuffer<E[]> syncBuffer,
                       IElementFilter<E> filter)

Method Detail

handleChunk

protected void handleChunk(E[] chunk)

Adds the chunk to the syncBuffer and updates the BOpStats.

Specified by:

handleChunk in class AbstractUnsynchronizedArrayBuffer<E extends IBindingSet>

Parameters:

chunk - A chunk of IBindingSets to be output.