Package nz.org.riskscape.engine.sched

Class CombinedPageBuffer

java.lang.Object

nz.org.riskscape.engine.sched.CombinedPageBuffer

All Implemented Interfaces:

ReadPageBuffer

public class CombinedPageBuffer
extends Object
implements ReadPageBuffer

Combines multiple ReadPageBuffers into one, for convenience

Constructor Summary

Constructors

Constructor	Description
CombinedPageBuffer(List<ReadPageBuffer> buffers)
CombinedPageBuffer(ReadPageBuffer... toRead)

Method Summary

Modifier and Type	Method	Description
boolean	isComplete()
boolean	isEmpty()
long	numTuplesRead()
Page.ReadOnlyPage	read()
int	size()

Methods inherited from class java.lang.Object

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

Constructor Details

CombinedPageBuffer

public CombinedPageBuffer(ReadPageBuffer... toRead)

CombinedPageBuffer

public CombinedPageBuffer(List<ReadPageBuffer> buffers)

Method Details

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface ReadPageBuffer

Returns:

true if there are no more pages in the buffer to read (because we're waiting for the upstream worker task to write more).

isComplete

public boolean isComplete()

Specified by:

isComplete in interface ReadPageBuffer

Returns:

true if there are no more pages in the buffer to read (because the upstream worker task has finished writing all its output).

read

public Page.ReadOnlyPage read()

Specified by:

read in interface ReadPageBuffer

Returns:

a page of Tuples to read, or null if there's no Tuples to read

numTuplesRead

public long numTuplesRead()

Specified by:

numTuplesRead in interface ReadPageBuffer

Returns:

the total number of Tuples read from the buffer (for diagnostics).

size

public int size()

Specified by:

size in interface ReadPageBuffer

Returns:

the number of unread tuples in unallocated pages in this buffer. It doesn't include the number of tuples that are in pages currently being read.