com.j_spaces.core.cache.offHeap

Class BlobStoreOperationsWrapper

java.lang.Object

com.gigaspaces.server.blobstore.BlobStoreStorageHandler

com.j_spaces.core.cache.offHeap.BlobStoreExtendedStorageHandler

com.j_spaces.core.cache.offHeap.BlobStoreOperationsWrapper

public class BlobStoreOperationsWrapper
extends BlobStoreExtendedStorageHandler

provide a wrapper over blobstore methods, used for serialization to byte-array, trapping stats etc

Since:

10.0

Author:

yechiel

Constructor Summary

Constructors

Constructor and Description
BlobStoreOperationsWrapper(CacheManager cacheManager, BlobStoreStorageHandler blobStore)

Method Summary

Modifier and Type	Method and Description
Object	add(Serializable id, Serializable data, BlobStoreObjectType objectType) Add the specified id with the specified data .
void	close() .
List<BlobStoreBulkOperationResult>	executeBulk(List<BlobStoreBulkOperationRequest> operations, BlobStoreObjectType objectType, boolean transactional) .
Serializable	get(Serializable id, Object position, BlobStoreObjectType objectType) Returns the data to which the specified id is mapped,
Serializable	get(Serializable id, Object position, BlobStoreObjectType objectType, boolean indexesPartOnly) Returns the data to which the specified id is mapped,
ExecutorService	getPreFetchPool() get the preFetchThread pool
Properties	getProperties() .
void	initialize(BlobStoreConfig blobStoreConfig) initialize a blob-store implementation.
DataIterator<BlobStoreGetBulkOperationResult>	iterator(BlobStoreObjectType objectType) .
Serializable	remove(Serializable id, Object position, BlobStoreObjectType objectType) Removes the id (and its corresponding data) from this FDF.
void	removeIfExists(Serializable id, Object position, BlobStoreObjectType objectType) Removes the id (and its corresponding data) from this FDF.
Object	replace(Serializable id, Serializable data, Object position, BlobStoreObjectType objectType) Replace the data to which the specified id is mapped with new data,

Methods inherited from class java.lang.Object

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

Constructor Detail

BlobStoreOperationsWrapper

public BlobStoreOperationsWrapper(CacheManager cacheManager,
                                  BlobStoreStorageHandler blobStore)

Method Detail

initialize

public void initialize(BlobStoreConfig blobStoreConfig)

Description copied from class: BlobStoreStorageHandler

initialize a blob-store implementation.

Overrides:

initialize in class BlobStoreStorageHandler

Parameters:

blobStoreConfig - - Configuration for blobstore implementation.

getProperties

public Properties getProperties()

Description copied from class: BlobStoreStorageHandler

. returns the properties passed (and also optionally set) by the blobstore handler.

Overrides:

getProperties in class BlobStoreStorageHandler

Returns:

properties.

add

public Object add(Serializable id,
                  Serializable data,
                  BlobStoreObjectType objectType)

Description copied from class: BlobStoreStorageHandler

Add the specified id with the specified data . Neither the id nor the data can be null.

Specified by:

add in class BlobStoreStorageHandler

Parameters:

id - id with which the specified value is to be associated

data - data to be associated with the specified id

objectType - the object type - one of BlobStoreObjectType values

Returns:

an optional position object which will be used as a pointer of locating the id, if the operation succeeded, or null if irrelevant

get

public Serializable get(Serializable id,
                        Object position,
                        BlobStoreObjectType objectType)

Description copied from class: BlobStoreStorageHandler

Returns the data to which the specified id is mapped,

Specified by:

get in class BlobStoreStorageHandler

Parameters:

id - id with which the specified data is to be associated

position - optional position object which will be used as a pointer of locating the id, or null if irrelevant

objectType - the object type - one of BlobStoreObjectType values

Returns:

the data to which the specified id is mapped,

get

public Serializable get(Serializable id,
                        Object position,
                        BlobStoreObjectType objectType,
                        boolean indexesPartOnly)

Description copied from class: BlobStoreExtendedStorageHandler

Returns the data to which the specified id is mapped,

Specified by:

get in class BlobStoreExtendedStorageHandler

Parameters:

id - id with which the specified data is to be associated

position - an optional position object which will be used as a pointer of locating the id, or null if irrelevant

objectType - the object type - one of BlobStoreObjectType values

indexesPartOnly - if true only the indexed fields are returned

Returns:

the data to which the specified id is mapped,

replace

public Object replace(Serializable id,
                      Serializable data,
                      Object position,
                      BlobStoreObjectType objectType)

Description copied from class: BlobStoreStorageHandler

Replace the data to which the specified id is mapped with new data,

Specified by:

replace in class BlobStoreStorageHandler

Parameters:

id - id with which the specified data is to be associated

data - the new data to replace the existing one.

position - optional position object which will be used as a pointer of locating the id, or null if irrelevant

objectType - the object type - one of BlobStoreObjectType values

Returns:

the new postion - an optional position object which will be used as a pointer of locating the id, or null if irrelevant

remove

public Serializable remove(Serializable id,
                           Object position,
                           BlobStoreObjectType objectType)

Description copied from class: BlobStoreStorageHandler

Removes the id (and its corresponding data) from this FDF.

Specified by:

remove in class BlobStoreStorageHandler

Parameters:

id - the key that needs to be removed

position - optional position object which will be used as a pointer of locating the id, or null if irrelevant

objectType - the object type - one of BlobStoreObjectType values

Returns:

the data to which the specified id is mapped,

removeIfExists

public void removeIfExists(Serializable id,
                           Object position,
                           BlobStoreObjectType objectType)

Description copied from class: BlobStoreExtendedStorageHandler

Removes the id (and its corresponding data) from this FDF. return false if no such object exists

Specified by:

removeIfExists in class BlobStoreExtendedStorageHandler

Parameters:

id - the key that needs to be removed

position - an optional position object which will be used as a pointer of locating the id, or null if irrelevant

objectType - the object type - one of BlobStoreObjectType values

executeBulk

public List<BlobStoreBulkOperationResult> executeBulk(List<BlobStoreBulkOperationRequest> operations,
                                                      BlobStoreObjectType objectType,
                                                      boolean transactional)

Description copied from class: BlobStoreStorageHandler

. execute a bulk of operations on the blobstore. return a corresoping list of results note- a non-abstract method, if not implemented the individual operations will be executed one by one

Overrides:

executeBulk in class BlobStoreStorageHandler

Parameters:

operations - - a list of operations to perform

objectType - the object type - one of BlobStoreObjectType values

transactional - - true if the bulk is to be performed in the blobstore as one logical transaction if the blobstore supports transactions, false otherwise

Returns:

a list of results which corresponds to the input list of operations. if one or more operations fail the returned result element will contain exception . if transactional parameter is true a general exception should be thrown instead of a returned result element with exception data

iterator

public DataIterator<BlobStoreGetBulkOperationResult> iterator(BlobStoreObjectType objectType)

Description copied from class: BlobStoreStorageHandler

. creates an iterator over the blobstore objeccts. note- a non-abstract method, if not implemented null will be returned

Overrides:

iterator in class BlobStoreStorageHandler

Parameters:

objectType - the object type - one of BlobStoreObjectType values

Returns:

an iterator over the blobstore objects which belong to the requested objectType.

close

public void close()

Description copied from class: BlobStoreStorageHandler

. close the blobstore handler. note- a non-abstract method

Overrides:

close in class BlobStoreStorageHandler

getPreFetchPool

public ExecutorService getPreFetchPool()

Description copied from class: BlobStoreExtendedStorageHandler

get the preFetchThread pool

Specified by:

getPreFetchPool in class BlobStoreExtendedStorageHandler