public abstract class BlobStoreExtendedStorageHandler extends Object
Constructor and Description |
---|
BlobStoreExtendedStorageHandler() |
Modifier and Type | Method and Description |
---|---|
abstract 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)
.
|
abstract Serializable |
get(Serializable id,
Object position,
BlobStoreObjectType objectType,
boolean indexesPartOnly,
IBlobStoreOffHeapInfo offHeapInfo)
Returns the data to which the specified id is mapped,
|
abstract Serializable |
get(Serializable id,
Object position,
BlobStoreObjectType objectType,
IBlobStoreOffHeapInfo offHeapInfo)
Returns the data to which the specified id is mapped,
|
abstract OffHeapMemoryPool |
getOffHeapCache() |
abstract AbstractMemoryPool |
getOffHeapStore() |
abstract ExecutorService |
getPreFetchPool()
get the preFetchThread pool
|
Properties |
getProperties()
.
|
abstract BlobStoreStorageStatistics |
getStorageStatistics() |
void |
initialize(BlobStoreConfig blobStoreConfig)
initialize a blob-store implementation.
|
abstract DataIterator<BlobStoreGetBulkOperationResult> |
initialLoadIterator()
Creates an iterator over the blobstore objects in space initial load stage only.
|
DataIterator<BlobStoreGetBulkOperationResult> |
iterator(BlobStoreObjectType objectType)
.
|
abstract Serializable |
remove(Serializable id,
Object position,
BlobStoreObjectType objectType,
IBlobStoreOffHeapInfo offHeapInfo)
Removes the id (and its corresponding data) from this FDF.
|
abstract void |
removeIfExists(Serializable id,
Object position,
BlobStoreObjectType objectType,
IBlobStoreOffHeapInfo offHeapInfo)
Removes the id (and its corresponding data) from this FDF.
|
abstract 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 void initialize(BlobStoreConfig blobStoreConfig)
blobStoreConfig
- - Configuration for blobstore implementation.public abstract Object add(Serializable id, Serializable data, BlobStoreObjectType objectType, IBlobStoreOffHeapInfo offHeapInfo)
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 valuesBlobStoreException
- if the specified id already exist
or container does not exist or
other failure.public abstract Object replace(Serializable id, Serializable data, Object position, BlobStoreObjectType objectType, IBlobStoreOffHeapInfo offHeapInfo)
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 valuesBlobStoreException
- if the specified id does not
exist.public abstract Serializable get(Serializable id, Object position, BlobStoreObjectType objectType, IBlobStoreOffHeapInfo offHeapInfo)
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 valuesBlobStoreException
- if the specified id does not
exist.public abstract Serializable get(Serializable id, Object position, BlobStoreObjectType objectType, boolean indexesPartOnly, IBlobStoreOffHeapInfo offHeapInfo)
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 returnedBlobStoreException
- if the specified id does not
exist.public abstract Serializable remove(Serializable id, Object position, BlobStoreObjectType objectType, IBlobStoreOffHeapInfo offHeapInfo)
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 valuesBlobStoreException
- if the id does not exist.public abstract void removeIfExists(Serializable id, Object position, BlobStoreObjectType objectType, IBlobStoreOffHeapInfo offHeapInfo)
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 valuesBlobStoreException
- if the id does not exist.public List<BlobStoreBulkOperationResult> executeBulk(List<BlobStoreBulkOperationRequest> operations, BlobStoreObjectType objectType, boolean transactional)
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)
objectType
- the object type - one of BlobStoreObjectType valuesBlobStoreException
- in case of a problenm.public Properties getProperties()
public void close()
public abstract ExecutorService getPreFetchPool()
public abstract DataIterator<BlobStoreGetBulkOperationResult> initialLoadIterator()
public abstract OffHeapMemoryPool getOffHeapCache()
public abstract AbstractMemoryPool getOffHeapStore()
public abstract BlobStoreStorageStatistics getStorageStatistics()
Copyright © GigaSpaces.