com.bigdata.bop.engine

Class BlockingBufferWithStats<E>

java.lang.Object

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

com.bigdata.bop.engine.BlockingBufferWithStats<E>

All Implemented Interfaces:

IBlockingBuffer<E>, IBuffer<E>, IRunnableBuffer<E>

public class BlockingBufferWithStats<E>
extends BlockingBuffer<E>

Extended to use the BufferAnnotations to provision the BlockingBuffer and to track the BOpStats as chunks are added to the buffer.

Version:

$Id: BlockingBufferWithStats.java 3838 2010-10-22 19:45:33Z thompsonbry $

Author:

Bryan Thompson

Nested Class Summary

Nested classes/interfaces inherited from class com.bigdata.relation.accesspath.BlockingBuffer

BlockingBuffer.BlockingIterator

Field Summary

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

DEFAULT_CONSUMER_CHUNK_TIMEOUT, DEFAULT_CONSUMER_CHUNK_TIMEOUT_UNIT, DEFAULT_MINIMUM_CHUNK_SIZE, DEFAULT_PRODUCER_QUEUE_CAPACITY, log

Constructor Summary

Constructors

Constructor and Description
BlockingBufferWithStats(PipelineOp op, BOpStats stats)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	add(E e, long timeout, TimeUnit unit) Overridden to track BOpStats.unitsOut and BOpStats.chunksOut.

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

abort, add, clear, close, combineChunks, flush, getChunksAddedCount, getChunkTimeout, getElementsAddedCount, getElementsOnQueueCount, getFuture, getMinimumChunkSize, isEmpty, isOpen, isOrdered, iterator, reset, setFuture, size, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockingBufferWithStats

public BlockingBufferWithStats(PipelineOp op,
                       BOpStats stats)

Method Detail

add

public boolean add(E e,
          long timeout,
          TimeUnit unit)
            throws InterruptedException

Overridden to track BOpStats.unitsOut and BOpStats.chunksOut.

Note: BOpStats.chunksOut will report the #of chunks added to this buffer. However, the buffer MAY combine chunks either on add() or when drained by the iterator so the actual #of chunks read back from the iterator MAY differ.

Add element to the buffer.

Overrides:

add in class BlockingBuffer<E>

Parameters:

e - The element.

timeout - The timeout.

unit - The unit in which the timeout is expressed.

Returns:

true iff the element was added to the buffer ( false indicates that the timeout expired before the element could be added to the buffer).

Throws:

InterruptedException - if interrupted