com.bigdata.service.proxy

Class RemoteChunkedIterator<E>

java.lang.Object

com.bigdata.service.proxy.RemoteChunkedIterator<E>

Type Parameters:

E - The generic type of the component elements visited by the source iterator.

All Implemented Interfaces:

IRemoteChunkedIterator<E>, Remote

public class RemoteChunkedIterator<E>
extends Object
implements IRemoteChunkedIterator<E>

Wrapper for an IAsynchronousIterator exposing an interface suitable for export as a proxy object using RMI to communicate back with itself and pull data efficiently from the source iterator.

Version:

$Id$

Author:

Bryan Thompson

Field Summary

Fields

Modifier and Type	Field and Description
protected static boolean	DEBUG
protected static boolean	INFO
protected static org.apache.log4j.Logger	log

Constructor Summary

Constructors

Constructor and Description
RemoteChunkedIterator(IAsynchronousIterator<E[]> sourceIterator, IStreamSerializer<E[]> serializer, IKeyOrder<E> keyOrder)

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Close the source iterator.
IRemoteChunk<E>	nextChunk() Return the next IRemoteChunk from the source iterator.

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final transient org.apache.log4j.Logger log

INFO

protected static final boolean INFO

DEBUG

protected static final boolean DEBUG

Constructor Detail

RemoteChunkedIterator

public RemoteChunkedIterator(IAsynchronousIterator<E[]> sourceIterator,
                     IStreamSerializer<E[]> serializer,
                     IKeyOrder<E> keyOrder)

Parameters:

sourceIterator - The source iterator.

serializer - The object that will be used to (de-)serialize the elements.

keyOrder - The natural order of the visited elements if known and otherwise null.

Method Detail

close

public void close()
           throws IOException

Close the source iterator.

Specified by:

close in interface IRemoteChunkedIterator<E>

Throws:

IOException

nextChunk

public IRemoteChunk<E> nextChunk()
                          throws IOException

Return the next IRemoteChunk from the source iterator. If it is exhausted then return an IRemoteChunk which indicates that no more results are available.

Specified by:

nextChunk in interface IRemoteChunkedIterator<E>

Returns:

The next IRemoteChunk.

Throws:

IOException