com.bigdata.bop.join

Class AbstractHashJoinUtilityTestCase.TestBuffer<E>

java.lang.Object

com.bigdata.bop.join.AbstractHashJoinUtilityTestCase.TestBuffer<E>

All Implemented Interfaces:

IBuffer<E>

Enclosing class:

AbstractHashJoinUtilityTestCase

protected static class AbstractHashJoinUtilityTestCase.TestBuffer<E>
extends Object
implements IBuffer<E>

A buffer which absorbs solutions and let's us replay them via an iterator.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractHashJoinUtilityTestCase.TestBuffer()

Method Summary

Methods

Modifier and Type	Method and Description
void	add(E e) Add an element to the buffer.
long	flush() Flush the buffer and return the #of elements written on the backing IRelation since the counter was last IBuffer.reset() (the mutationCount).
boolean	isEmpty() True iff there are no elements in the buffer.
Iterator<E>	iterator()
void	reset() Reset the state of the buffer, including the counter whose value is reported by IBuffer.flush().
int	size() The #of elements currently in the buffer.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractHashJoinUtilityTestCase.TestBuffer

protected AbstractHashJoinUtilityTestCase.TestBuffer()

Method Detail

iterator

public Iterator<E> iterator()

size

public int size()

Description copied from interface: IBuffer

The #of elements currently in the buffer.

Specified by:

size in interface IBuffer<E>

isEmpty

public boolean isEmpty()

Description copied from interface: IBuffer

True iff there are no elements in the buffer.

Specified by:

isEmpty in interface IBuffer<E>

add

public void add(E e)

Description copied from interface: IBuffer

Add an element to the buffer.

Specified by:

add in interface IBuffer<E>

Parameters:

e - The element

flush

public long flush()

Description copied from interface: IBuffer

Flush the buffer and return the #of elements written on the backing IRelation since the counter was last IBuffer.reset() (the mutationCount).

Note: If the buffer does not write on an IRelation then it SHOULD return ZERO(0).

Specified by:

flush in interface IBuffer<E>

Returns:

The #of elements written on the backing IRelation. See IMutableRelation

reset

public void reset()

Description copied from interface: IBuffer

Reset the state of the buffer, including the counter whose value is reported by IBuffer.flush(). Any data in the buffer will be discarded.

Specified by:

reset in interface IBuffer<E>