com.bigdata.service.proxy
Class ClientRunnableBuffer<E,V>

java.lang.Object
  com.bigdata.service.proxy.ClientBuffer<E>
      com.bigdata.service.proxy.ClientRunnableBuffer<E,V>

All Implemented Interfaces:

IBuffer<E>, IRunnableBuffer<E>, Serializable

public class ClientRunnableBuffer<E,V>
extends ClientBuffer<E>
implements IRunnableBuffer<E>

Serializable class wraps a RemoteRunnableBuffer delegating methods through to the IRunnableBuffer on the remote service while masquerading IOExceptions so that we can implement the IRunnableBuffer API.

Version:

$Id: ClientRunnableBuffer.java 2265 2009-10-26 12:51:06Z thompsonbry $

Author:

Bryan Thompson

See Also:

Serialized Form

Constructor Summary

ClientRunnableBuffer(RemoteRunnableBuffer<E,V> buffer)

Method Summary

void	abort(Throwable cause) Signal abnormal termination of the process writing on the buffer.
void	close() Signal that no more data will be written on this buffer (this is required in order for the #iterator() to know when no more data will be made available).
Future<V>	getFuture() The Future for the worker task.
boolean	isOpen() Return true if the buffer is open.

Methods inherited from class com.bigdata.service.proxy.ClientBuffer

add, flush, isEmpty, reset, size

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.bigdata.relation.accesspath.IRunnableBuffer

add

Methods inherited from interface com.bigdata.relation.accesspath.IBuffer

flush, isEmpty, reset, size

Constructor Detail

ClientRunnableBuffer

public ClientRunnableBuffer(RemoteRunnableBuffer<E,V> buffer)

Parameters:

buffer -

Method Detail

isOpen

public boolean isOpen()

Description copied from interface: IRunnableBuffer

Return true if the buffer is open.

Specified by:

isOpen in interface IRunnableBuffer<E>

abort

public void abort(Throwable cause)

Description copied from interface: IRunnableBuffer

Signal abnormal termination of the process writing on the buffer. The buffer will be closed. The #iterator() will report the cause via a wrapped exception the next time any method on its interface is invoked. The internal queue may be cleared once this method is invoked.

Specified by:

abort in interface IRunnableBuffer<E>

Parameters:

cause - The exception thrown by the processing writing on the buffer.

close

public void close()

Description copied from interface: IRunnableBuffer

Signal that no more data will be written on this buffer (this is required in order for the #iterator() to know when no more data will be made available).

Specified by:

close in interface IRunnableBuffer<E>

getFuture

public Future<V> getFuture()

Description copied from interface: IRunnableBuffer

The Future for the worker task.

Specified by:

getFuture in interface IRunnableBuffer<E>

Returns:

The Future -or- null if no Future has been set.