com.bigdata.relation.rule.eval.pipeline

Class UnsyncLocalOutputBuffer<E extends IBindingSet>

java.lang.Object

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

com.bigdata.relation.rule.eval.pipeline.UnsyncLocalOutputBuffer<E>

Type Parameters:

E -

All Implemented Interfaces:

IBuffer<E>

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

Keeps track of the chunks of binding sets that are generated on the caller's JoinStats.

Version:

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

Author:

Bryan Thompson

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
protected void	handleChunk(E[] chunk) Adds the chunk to the syncBuffer and updated the JoinStats to reflect the #of IBindingSet chunks that will be output and the #of IBindingSets in those chunks.

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(JoinStats joinStats,
                       int capacity,
                       IBlockingBuffer<E[]> syncBuffer)

Parameters:

joinTask - The task that is writing on this buffer.

capacity - The capacity of this buffer.

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

Method Detail

handleChunk

protected void handleChunk(E[] chunk)

Adds the chunk to the syncBuffer and updated the JoinStats to reflect the #of IBindingSet chunks that will be output and the #of IBindingSets in those chunks.

Specified by:

handleChunk in class AbstractUnsynchronizedArrayBuffer<E extends IBindingSet>

Parameters:

chunk - A chunk of IBindingSets to be output.