com.bigdata.service

Class ResourceService.ReadBufferTask

java.lang.Object

com.bigdata.service.ResourceService.FetchResourceTask<UUID,ByteBuffer>

com.bigdata.service.ResourceService.ReadBufferTask

All Implemented Interfaces:

Callable<ByteBuffer>

Enclosing class:

ResourceService

public static class ResourceService.ReadBufferTask
extends ResourceService.FetchResourceTask<UUID,ByteBuffer>

Class sends a request for a remote ByteBuffer and then receives the data into a local ByteBuffer.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
ResourceService.ReadBufferTask(InetSocketAddress addr, UUID id, ByteBuffer outbuf)

Method Summary

Methods

Modifier and Type	Method and Description
ByteBuffer	call() Issue a request to the remote service for the ByteBuffer on that service which was identified to the constructor and then accept the data into the local ByteBuffer provided to the constructor.
UUID	logId() The logical identifier for the resource.
ByteBuffer	logResource() The resource.

Methods inherited from class com.bigdata.service.ResourceService.FetchResourceTask

transfer

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final org.apache.log4j.Logger log

Constructor Detail

ResourceService.ReadBufferTask

public ResourceService.ReadBufferTask(InetSocketAddress addr,
                              UUID id,
                              ByteBuffer outbuf)

Parameters:

addr - The Internet address and port at which to connect the service from which the resource will be read.

id - The id that identifies the source ByteBuffer.

outbuf - The ByteBuffer to which the data from the remote source ByteBuffer will be transferred.

Method Detail

logId

public UUID logId()

Description copied from class: ResourceService.FetchResourceTask

The logical identifier for the resource.

logResource

public ByteBuffer logResource()

Description copied from class: ResourceService.FetchResourceTask

The resource.

call

public ByteBuffer call()
                throws Exception

Issue a request to the remote service for the ByteBuffer on that service which was identified to the constructor and then accept the data into the local ByteBuffer provided to the constructor.

Returns:

A mutable view onto the received data within the caller's ByteBuffer. The data read from the remote service are available for reading from Buffer.position() to Buffer.limit() in the returned buffer.

Throws:

Exception - if something goes wrong (buffer does not exist, IO error, overflow in the local buffer when receiving the data from the remote service, etc.).