org.treetank.io.jclouds

Class JCloudsReader

java.lang.Object

org.treetank.io.jclouds.JCloudsReader

All Implemented Interfaces:

IBackendReader

public class JCloudsReader
extends Object
implements IBackendReader

Accessing the Cloud storage for reading in a multithreaded manner.

Author:

Sebastian Graf, University of Konstanz

Field Summary

Fields

Modifier and Type	Field and Description
protected org.jclouds.blobstore.BlobStore	mBlobStore Blob Store for Reading the data.
protected IByteHandler.IByteHandlerPipeline	mByteHandler Inflater to decompress.
protected com.google.common.cache.Cache<Long,IBucket>	mCache Cache for reading data.
protected String	mResourceName Resource name of this container and the database.

Constructor Summary

Constructors

Constructor and Description
JCloudsReader(org.jclouds.blobstore.BlobStore pBlobStore, BucketFactory pFac, IByteHandler.IByteHandlerPipeline pByteHandler, String pResourceName)

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Closing the storage.
IBucket	read(long pKey) Getting a reference for the given pointer.
UberBucket	readUber() Reading the UberBucket

Methods inherited from class java.lang.Object

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

Field Detail

mBlobStore

protected final org.jclouds.blobstore.BlobStore mBlobStore

Blob Store for Reading the data.

mByteHandler

protected final IByteHandler.IByteHandlerPipeline mByteHandler

Inflater to decompress.

mResourceName

protected final String mResourceName

Resource name of this container and the database.

mCache

protected final com.google.common.cache.Cache<Long,IBucket> mCache

Cache for reading data.

Constructor Detail

JCloudsReader

public JCloudsReader(org.jclouds.blobstore.BlobStore pBlobStore,
             BucketFactory pFac,
             IByteHandler.IByteHandlerPipeline pByteHandler,
             String pResourceName)
              throws TTException

Throws:

TTException

Method Detail

readUber

public UberBucket readUber()
                    throws TTIOException

Reading the UberBucket

Specified by:

readUber in interface IBackendReader

Returns:

the most recent UberBucket

Throws:

TTIOException

read

public IBucket read(long pKey)
             throws TTIOException

Getting a reference for the given pointer.

Specified by:

read in interface IBackendReader

Parameters:

pKey - the reference for the bucket to be determined

Returns:

a IBucket as the base for a bucket

Throws:

TTIOException

close

public void close()
           throws TTIOException

Closing the storage.

Specified by:

close in interface IBackendReader

Throws:

TTIOException - if something bad happens while access