voldemort.store.nonblockingstore
Class ThreadPoolBasedNonblockingStoreImpl

java.lang.Object
  voldemort.store.nonblockingstore.ThreadPoolBasedNonblockingStoreImpl

All Implemented Interfaces:

NonblockingStore

public class ThreadPoolBasedNonblockingStoreImpl
extends java.lang.Object
implements NonblockingStore

Constructor Summary

ThreadPoolBasedNonblockingStoreImpl(java.util.concurrent.ExecutorService executor, Store<ByteArray,byte[],byte[]> innerStore)

Method Summary

void	close()
void	submitDeleteRequest(ByteArray key, Version version, NonblockingStoreCallback callback, long timeoutMs)
void	submitGetAllRequest(java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms, NonblockingStoreCallback callback, long timeoutMs)
void	submitGetRequest(ByteArray key, byte[] transforms, NonblockingStoreCallback callback, long timeoutMs)
void	submitGetVersionsRequest(ByteArray key, NonblockingStoreCallback callback, long timeoutMs)
void	submitPutRequest(ByteArray key, Versioned<byte[]> value, byte[] transforms, NonblockingStoreCallback callback, long timeoutMs)

Methods inherited from class java.lang.Object

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

Constructor Detail

ThreadPoolBasedNonblockingStoreImpl

public ThreadPoolBasedNonblockingStoreImpl(java.util.concurrent.ExecutorService executor,
                                           Store<ByteArray,byte[],byte[]> innerStore)

Method Detail

submitGetAllRequest

public void submitGetAllRequest(java.lang.Iterable<ByteArray> keys,
                                java.util.Map<ByteArray,byte[]> transforms,
                                NonblockingStoreCallback callback,
                                long timeoutMs)

Specified by:

submitGetAllRequest in interface NonblockingStore

submitGetRequest

public void submitGetRequest(ByteArray key,
                             byte[] transforms,
                             NonblockingStoreCallback callback,
                             long timeoutMs)

Specified by:

submitGetRequest in interface NonblockingStore

submitGetVersionsRequest

public void submitGetVersionsRequest(ByteArray key,
                                     NonblockingStoreCallback callback,
                                     long timeoutMs)

Specified by:

submitGetVersionsRequest in interface NonblockingStore

submitPutRequest

public void submitPutRequest(ByteArray key,
                             Versioned<byte[]> value,
                             byte[] transforms,
                             NonblockingStoreCallback callback,
                             long timeoutMs)

Specified by:

submitPutRequest in interface NonblockingStore

submitDeleteRequest

public void submitDeleteRequest(ByteArray key,
                                Version version,
                                NonblockingStoreCallback callback,
                                long timeoutMs)

Specified by:

submitDeleteRequest in interface NonblockingStore

close

public void close()
           throws VoldemortException

Specified by:

close in interface NonblockingStore

Throws:

VoldemortException