public class BlobStoreOperationsWrapper extends BlobStoreExtendedStorageHandler
Constructor and Description |
---|
BlobStoreOperationsWrapper(CacheManager cacheManager,
BlobStoreStorageHandler blobStore) |
Modifier and Type | Method and Description |
---|---|
Object |
add(Serializable id,
Serializable data,
BlobStoreObjectType objectType,
IBlobStoreOffHeapInfo offHeapInfo)
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,
boolean indexesPartOnly,
IBlobStoreOffHeapInfo offHeapInfo)
Returns the data to which the specified id is mapped,
|
Serializable |
get(Serializable id,
Object position,
BlobStoreObjectType objectType,
IBlobStoreOffHeapInfo offHeapInfo)
Returns the data to which the specified id is mapped,
|
OffHeapMemoryPool |
getOffHeapCache() |
AbstractMemoryPool |
getOffHeapStore() |
ExecutorService |
getPreFetchPool()
get the preFetchThread pool
|
Properties |
getProperties()
.
|
BlobStoreStorageStatistics |
getStorageStatistics() |
void |
initialize(BlobStoreConfig blobStoreConfig)
initialize a blob-store implementation.
|
DataIterator<BlobStoreGetBulkOperationResult> |
initialLoadIterator()
Creates an iterator over the blobstore objects in space initial load stage only.
|
DataIterator<BlobStoreGetBulkOperationResult> |
iterator(BlobStoreObjectType objectType)
.
|
Serializable |
remove(Serializable id,
Object position,
BlobStoreObjectType objectType,
IBlobStoreOffHeapInfo offHeapInfo)
Removes the id (and its corresponding data) from this FDF.
|
void |
removeIfExists(Serializable id,
Object position,
BlobStoreObjectType objectType,
IBlobStoreOffHeapInfo offHeapInfo)
Removes the id (and its corresponding data) from this FDF.
|
Object |
replace(Serializable id,
Serializable data,
Object position,
BlobStoreObjectType objectType,
IBlobStoreOffHeapInfo offHeapInfo)
Replace the data to which the specified id is mapped with new data,
|
public BlobStoreOperationsWrapper(CacheManager cacheManager, BlobStoreStorageHandler blobStore)
public OffHeapMemoryPool getOffHeapCache()
getOffHeapCache
in class BlobStoreExtendedStorageHandler
public AbstractMemoryPool getOffHeapStore()
getOffHeapStore
in class BlobStoreExtendedStorageHandler
public BlobStoreStorageStatistics getStorageStatistics()
getStorageStatistics
in class BlobStoreExtendedStorageHandler
public void initialize(BlobStoreConfig blobStoreConfig)
BlobStoreExtendedStorageHandler
initialize
in class BlobStoreExtendedStorageHandler
blobStoreConfig
- - Configuration for blobstore implementation.public Properties getProperties()
BlobStoreExtendedStorageHandler
getProperties
in class BlobStoreExtendedStorageHandler
public Object add(Serializable id, Serializable data, BlobStoreObjectType objectType, IBlobStoreOffHeapInfo offHeapInfo)
BlobStoreExtendedStorageHandler
add
in class BlobStoreExtendedStorageHandler
id
- id with which the specified value is to be associateddata
- data to be associated with the specified idobjectType
- the object type - one of BlobStoreObjectType valuespublic Serializable get(Serializable id, Object position, BlobStoreObjectType objectType, IBlobStoreOffHeapInfo offHeapInfo)
BlobStoreExtendedStorageHandler
get
in class BlobStoreExtendedStorageHandler
id
- id with which the specified data is to be associatedposition
- optional position object which will be used as a pointer of locating the
id, or null if irrelevantobjectType
- the object type - one of BlobStoreObjectType valuespublic Serializable get(Serializable id, Object position, BlobStoreObjectType objectType, boolean indexesPartOnly, IBlobStoreOffHeapInfo offHeapInfo)
BlobStoreExtendedStorageHandler
get
in class BlobStoreExtendedStorageHandler
id
- id with which the specified data is to be associatedposition
- an optional position object which will be used as a pointer of
locating the id, or null if irrelevantobjectType
- the object type - one of BlobStoreObjectType valuesindexesPartOnly
- if true only the indexed fields are returnedpublic Object replace(Serializable id, Serializable data, Object position, BlobStoreObjectType objectType, IBlobStoreOffHeapInfo offHeapInfo)
BlobStoreExtendedStorageHandler
replace
in class BlobStoreExtendedStorageHandler
id
- id with which the specified data is to be associateddata
- 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 irrelevantobjectType
- the object type - one of BlobStoreObjectType valuespublic Serializable remove(Serializable id, Object position, BlobStoreObjectType objectType, IBlobStoreOffHeapInfo offHeapInfo)
BlobStoreExtendedStorageHandler
remove
in class BlobStoreExtendedStorageHandler
id
- the key that needs to be removedposition
- optional position object which will be used as a pointer of locating the
id, or null if irrelevantobjectType
- the object type - one of BlobStoreObjectType valuespublic void removeIfExists(Serializable id, Object position, BlobStoreObjectType objectType, IBlobStoreOffHeapInfo offHeapInfo)
BlobStoreExtendedStorageHandler
removeIfExists
in class BlobStoreExtendedStorageHandler
id
- the key that needs to be removedposition
- an optional position object which will be used as a pointer of locating the
id, or null if irrelevantobjectType
- the object type - one of BlobStoreObjectType valuespublic List<BlobStoreBulkOperationResult> executeBulk(List<BlobStoreBulkOperationRequest> operations, BlobStoreObjectType objectType, boolean transactional)
BlobStoreExtendedStorageHandler
executeBulk
in class BlobStoreExtendedStorageHandler
operations
- - a list of operations to performobjectType
- the object type - one of BlobStoreObjectType valuestransactional
- - true if the bulk is to be performed in the blobstore as one logical
transaction if the blobstore supports transactions, false otherwisepublic DataIterator<BlobStoreGetBulkOperationResult> iterator(BlobStoreObjectType objectType)
BlobStoreExtendedStorageHandler
iterator
in class BlobStoreExtendedStorageHandler
objectType
- the object type - one of BlobStoreObjectType valuespublic DataIterator<BlobStoreGetBulkOperationResult> initialLoadIterator()
BlobStoreExtendedStorageHandler
initialLoadIterator
in class BlobStoreExtendedStorageHandler
public void close()
BlobStoreExtendedStorageHandler
close
in class BlobStoreExtendedStorageHandler
public ExecutorService getPreFetchPool()
BlobStoreExtendedStorageHandler
getPreFetchPool
in class BlobStoreExtendedStorageHandler
Copyright © GigaSpaces.