Package | Description |
---|---|
messif.algorithms.impl |
Implementation of basic search algorithms.
|
messif.buckets |
Storage classes capable of holding
objects . |
messif.buckets.impl |
Bucket implementations.
|
messif.buckets.index.impl |
Implementation of bucket indexes.
|
messif.buckets.split |
Bucket splitting support.
|
messif.buckets.storage |
Bucket physical storage support.
|
messif.buckets.storage.impl |
Implementations of physical bucket storage.
|
messif.netbucket |
Networked objects and buckets.
|
messif.netbucket.replication |
Replication support for remote buckets.
|
messif.objects.impl |
Implementation of basic data objects.
|
Modifier and Type | Method and Description |
---|---|
void |
SequentialScan.bulkInsert(BulkInsertOperation operation)
Bulk insertion.
|
void |
LocatorStorageAlgorithm.bulkInsertOperation(BulkInsertOperation op)
Implementation of the bulk-insert operation.
|
void |
ParallelSequentialScan.delete(DeleteByLocatorOperation operation)
Deletes objects by locators.
|
void |
SequentialScan.delete(DeleteByLocatorOperation operation)
Deletes objects by locators.
|
void |
ParallelSequentialScan.delete(DeleteOperation operation)
Deletes an object.
|
void |
SequentialScan.delete(DeleteOperation operation)
Deletes an object.
|
void |
LocatorStorageAlgorithm.deleteByLocatorOperation(DeleteByLocatorOperation op)
Implementation of the delete-by-locator operation.
|
void |
LocatorStorageAlgorithm.deleteOperation(DeleteOperation op)
Implementation of the delete operation.
|
void |
LocatorStorageAlgorithm.insertOperation(InsertOperation op)
Implementation of the insert operation.
|
protected void |
ParallelSequentialScan.processObjectInsert(java.util.Collection<? extends LocalAbstractObject> objects)
Processes the insertion of objects into buckets.
|
Modifier and Type | Class and Description |
---|---|
class |
CapacityFullException
Thrown to indicate that the hard capacity limit was exceeded.
|
class |
DuplicateObjectException
Thrown to indicate that the bucket already contains the inserted object.
|
class |
FilterRejectException
Thrown to indicate that the bucket filter rejects current operation.
|
class |
OccupationLowException
This exception indicates that the removal of an object from bucket is not possible,
because the minimal capacity limit was reached.
|
class |
StorageFailureException
This exception indicates that storing or reading object from bucket is not possible
due to lower layer storage exception.
|
class |
StorageInsertFailureException
This exception indicates that inserting objects into a bucket has failed.
|
Modifier and Type | Method and Description |
---|---|
boolean |
Addible.add(T object)
Adds the specified object to this instance.
|
LocalBucket |
BucketDispatcher.addBucket(LocalBucket bucket)
Add an existing bucket to this dispatcher.
|
abstract void |
Bucket.addObject(LocalAbstractObject object)
Insert a new object into this bucket.
|
void |
LocalBucket.addObject(LocalAbstractObject object) |
protected void |
LocalBucket.addObject(LocalAbstractObject object,
Addible<LocalAbstractObject> addible)
Check if the object
object can added to this bucket. |
int |
Bucket.addObjects(java.util.Collection<? extends LocalAbstractObject> objects)
Insert several new objects into this bucket.
|
int |
Bucket.addObjects(java.util.Iterator<? extends LocalAbstractObject> objects)
Insert several new objects to this bucket.
|
LocalBucket |
BucketDispatcher.createBucket()
Create new local bucket with the default storage class and default storage capacity.
|
LocalBucket |
BucketDispatcher.createBucket(java.lang.Class<? extends LocalBucket> storageClass)
Create new local bucket with specified storage class and default storage capacity.
|
LocalBucket |
BucketDispatcher.createBucket(java.lang.Class<? extends LocalBucket> storageClass,
java.util.Map<java.lang.String,java.lang.Object> storageClassParams)
Create new local bucket with specified storage class and default storage capacity.
|
LocalBucket |
BucketDispatcher.createBucket(java.lang.Class<? extends LocalBucket> storageClass,
java.util.Map<java.lang.String,java.lang.Object> storageClassParams,
long capacity,
long softCapacity,
long lowOccupation)
Create new local bucket with specified storage class and storage capacity (different from default values).
|
LocalBucket |
BucketDispatcher.createBucket(long capacity,
long softCapacity,
long lowOccupation)
Create new local bucket with default storage class and specified storage capacity.
|
abstract int |
Bucket.deleteAllObjects()
Delete all objects from this bucket.
|
int |
LocalBucket.deleteAllObjects() |
int |
Bucket.deleteObject(LocalAbstractObject object)
Delete all objects from this bucket that are
data-equals to
the specified object. |
abstract int |
Bucket.deleteObject(LocalAbstractObject object,
int deleteLimit)
Delete all objects from this bucket that are
data-equals to
the specified object. |
int |
LocalBucket.deleteObject(LocalAbstractObject object,
int deleteLimit) |
protected void |
LocalBucket.deleteObject(Removable<LocalAbstractObject> removable)
Check if the
object can be deleted from this bucket. |
int |
Bucket.deleteObject(java.lang.String locatorURI)
Delete all objects from this bucket that have the specified
locatorURI . |
abstract int |
Bucket.deleteObject(java.lang.String locatorURI,
int deleteLimit)
Delete all objects from this bucket that have the specified
locatorURI . |
int |
LocalBucket.deleteObject(java.lang.String locatorURI,
int deleteLimit) |
protected int |
LocalBucket.deleteObjects(ModifiableSearch<LocalAbstractObject> search,
int deleteLimit)
Delete objects that are retrieved by the given search.
|
LocalBucket |
BucketDispatcher.moveBucket(int bucketID,
BucketDispatcher targetDispatcher)
Move the bucket with the specified ID to another dispatcher.
|
void |
Removable.remove()
Removes the current object.
|
int |
Bucket.split(SplitPolicy policy,
java.util.List<Bucket> targetBuckets,
BucketDispatcher bucketCreator,
int whoStays)
Splits this bucket according to the specified policy.
|
Constructor and Description |
---|
StorageInsertFailureException(BucketStorageException e)
Creates a new instance of StorageInsertFailureException by copying the error code,
message, and cause from another
BucketStorageException . |
Modifier and Type | Method and Description |
---|---|
boolean |
AlgorithmStorageBucket.add(LocalAbstractObject object)
Stores the specified object in the encapsulated algorithm, i.e.
|
int |
AlgorithmStorageBucket.addObjects(java.util.Iterator<? extends LocalAbstractObject> objects) |
int |
AlgorithmStorageBucket.deleteObject(LocalAbstractObject object,
int deleteLimit)
Removes the given object by calling
DeleteOperation on the
encapsulated algorithm. |
int |
AlgorithmStorageBucket.deleteObject(java.lang.String locatorURI,
int deleteLimit)
Removes the given object by calling
DeleteByLocatorOperation on the
encapsulated algorithm. |
int |
AlgorithmStorageBucket.split(SplitPolicy policy,
java.util.List<Bucket> targetBuckets,
BucketDispatcher bucketCreator,
int whoStays)
Splits this bucket according to the specified policy.
|
Modifier and Type | Method and Description |
---|---|
boolean |
AddressStorageIndex.add(T object) |
boolean |
IntStorageIndex.add(T object) |
boolean |
LongStorageIndex.add(T object) |
boolean |
LongStorageMemoryIndex.add(T object) |
boolean |
LongStorageMemoryIndexStdSer.add(T object) |
protected int |
LongStorageMemoryIndex.insertionPoint(K key)
Searches for the point where to insert the object
object . |
protected int |
LongStorageMemoryIndexStdSer.insertionPoint(K key)
Searches for the point where to insert the object
object . |
protected int |
AddressStorageIndex.insertionPoint(T object)
Searches for the point where to insert the object
object . |
protected int |
IntStorageIndex.insertionPoint(T object)
Searches for the point where to insert the object
object . |
protected int |
LongStorageIndex.insertionPoint(T object)
Searches for the point where to insert the object
object . |
protected abstract T |
AbstractSearch.readNext()
Returns the next sibling object of the current one.
|
protected abstract T |
AbstractSearch.readPrevious()
Returns the previous sibling object of the current one.
|
void |
LongStorageMemoryIndex.reorderStorage(java.io.File newFile)
Switches this index to a new storage in which the data are ordered according
the this index's current order.
|
void |
LongStorageMemoryIndexStdSer.reorderStorage(java.io.File newFile)
Switches this index to a new storage in which the data are ordered according
the this index's current order.
|
protected void |
LongStorageIndex.sort()
Sorts the unsorted part of the array.
|
Modifier and Type | Method and Description |
---|---|
void |
SplittableAlgorithm.SplittableAlgorithmResult.markMovedObject(Algorithm algorithm,
LocalAbstractObject object)
Registers a move of one object into the result.
|
void |
SplittableAlgorithm.SplittableAlgorithmResult.markMovedObjects(Algorithm algorithm,
java.util.Collection<? extends LocalAbstractObject> objects)
Registers a move of objects into the result.
|
void |
SplittableAlgorithm.split(SplitPolicy policy,
SplittableAlgorithm.SplittableAlgorithmResult result,
int whoStays)
Split this algorithm according to the specified policy.
|
Modifier and Type | Class and Description |
---|---|
class |
InvalidAddressException
Exception that indicates that an invalid address has been used while
accessing a storage.
|
class |
ReadonlyStorageException
Exception that indicates that a write operation was requested on a
read-only storage.
|
Modifier and Type | Method and Description |
---|---|
T |
Address.read()
Reads the object stored at this address from the associated storage.
|
T |
IntAddress.read() |
T |
LongAddress.read() |
T |
IntStorage.read(int address)
Reads the object stored at the specified address in this storage.
|
T |
LongStorage.read(long address)
Reads the object stored at the specified address in this storage.
|
void |
Address.remove()
Removes the object stored at this address from the associated storage.
|
void |
IntAddress.remove() |
void |
LongAddress.remove() |
void |
IntStorage.remove(int address)
Removes the object stored at the specified address in this storage.
|
void |
LongStorage.remove(long address)
Removes the object stored at the specified address in this storage.
|
void |
LongAddress.rewrite(T object)
Stores given object to a given address where an object was already stored (typically the
same object was stored there and now it's being updated).
|
void |
LongStorage.rewrite(T object,
long address)
Stores given object to a given address where an object was already stored (typically the
same object was stored there and now it's being updated).
|
IntAddress<T> |
IntStorage.store(T object) |
LongAddress<T> |
LongStorage.store(T object) |
Address<T> |
Storage.store(T object)
Stores an object in this storage.
|
Modifier and Type | Method and Description |
---|---|
boolean |
DatabaseStorage.add(T object) |
boolean |
DiskStorage.add(T object) |
boolean |
MemoryStorage.add(T object) |
ModifiableParametric |
DatabaseStorage.ParametricColumnConvertor.convertFromColumnValue(ModifiableParametric value,
java.lang.Object column) |
T |
DatabaseStorage.ColumnConvertor.convertFromColumnValue(T value,
java.lang.Object column)
Returns an instance of object from the database column value.
|
T |
DatabaseStorage.FixedValueColumnConvertor.convertFromColumnValue(T value,
java.lang.Object column) |
T |
DatabaseStorage.BinarySerializableColumnConvertor.convertFromColumnValue(T value,
java.lang.Object column) |
T |
DatabaseStorage.LocalAbstractObjectTextStreamColumnConvertor.convertFromColumnValue(T value,
java.lang.Object column) |
T |
DatabaseStorage.MetaObjectTextStreamColumnConvertor.convertFromColumnValue(T value,
java.lang.Object column) |
T |
DatabaseStorage.BeanPropertyColumnConvertor.convertFromColumnValue(T value,
java.lang.Object column) |
java.lang.Object |
DatabaseStorage.LocalAbstractObjectTextStreamColumnConvertor.convertToColumnValue(LocalAbstractObject instance) |
java.lang.Object |
DatabaseStorage.ParametricColumnConvertor.convertToColumnValue(ModifiableParametric instance) |
java.lang.Object |
DatabaseStorage.ColumnConvertor.convertToColumnValue(T instance)
Returns a value that can be stored in a database column for the given instance.
|
java.lang.Object |
DatabaseStorage.FixedValueColumnConvertor.convertToColumnValue(T instance) |
java.lang.Object |
DatabaseStorage.BinarySerializableColumnConvertor.convertToColumnValue(T instance) |
java.lang.Object |
DatabaseStorage.MetaObjectTextStreamColumnConvertor.convertToColumnValue(T instance) |
java.lang.Object |
DatabaseStorage.BeanPropertyColumnConvertor.convertToColumnValue(T instance) |
protected java.sql.PreparedStatement |
DatabaseStorage.execute(java.sql.PreparedStatement statement,
java.lang.String sql,
java.lang.Integer primaryKey,
T object,
boolean returnGeneratedKeys)
Prepares and executes an SQL command.
|
T |
DatabaseStorage.read(int address) |
T |
MemoryStorage.read(int address) |
T |
DiskStorage.read(long position) |
void |
DatabaseStorage.remove(int address) |
void |
MemoryStorage.remove(int address) |
void |
DiskStorage.remove(long position) |
protected void |
DiskStorage.remove(long position,
int objectSize)
Removes object with size
objectSize at position position . |
void |
DiskStorage.rewrite(T object,
long position) |
IntAddress<T> |
DatabaseStorage.store(T object) |
LongAddress<T> |
DiskStorage.store(T object) |
LongAddress<T> |
DiskStorageFillGaps.store(T object) |
void |
DatabaseStorage.update(int address,
T object)
Updates the object on address
address with data from object . |
Modifier and Type | Method and Description |
---|---|
BucketStorageException |
BucketExceptionReplyMessage.getException()
Returns the bucket storage exception stored in this message.
|
Modifier and Type | Method and Description |
---|---|
void |
RemoteBucket.addObject(LocalAbstractObject object) |
int |
RemoteBucket.addObjects(java.util.Iterator<? extends LocalAbstractObject> objects) |
boolean |
NetworkBucketDispatcher.copyAllObjects(RemoteBucket remoteBucket,
RemoteBucket sourceRemoteBucket)
Copies all objects from the
sourceRemoteBucket to the remoteBucket on their network node. |
RemoteBucket |
NetworkBucketDispatcher.createRemoteBucket(NetworkNode atNetworkNode)
Creates a bucket on a remote network node.
|
RemoteBucket |
NetworkBucketDispatcher.createRemoteBucket(NetworkNode atNetworkNode,
java.lang.Class<? extends LocalBucket> storageClass,
java.util.Map<java.lang.String,java.lang.Object> storageClassParams,
long capacity,
long softCapacity)
Creates a bucket on a remote network node.
|
RemoteBucket |
NetworkBucketDispatcher.createRemoteBucket(NetworkNode atNetworkNode,
long capacity,
long softCapacity)
Creates a bucket on a remote network node with default class and params is created
but with specified capacity and soft capacity.
|
int |
RemoteBucket.deleteAllObjects() |
int |
RemoteBucket.deleteObject(LocalAbstractObject object,
int deleteLimit) |
int |
RemoteBucket.deleteObject(java.lang.String locatorURI,
int deleteLimit) |
BucketCreateReplyMessage |
BucketCreateRequestMessage.execute(BucketDispatcher bucketDispatcher) |
BucketManipulationReplyMessage |
BucketManipulationRequestMessage.execute(BucketDispatcher bucketDispatcher) |
BucketProcessQueryReplyMessage |
BucketProcessQueryRequestMessage.execute(BucketDispatcher bucketDispatcher) |
abstract T |
BucketRequestMessage.execute(BucketDispatcher bucketDispatcher)
Executes this request on the specified bucket dispatcher.
|
BucketSplitReplyMessage |
BucketSplitRequestMessage.execute(BucketDispatcher bucketDispatcher) |
protected <T extends BucketReplyMessage> |
NetworkBucketDispatcher.send(BucketRequestMessage<T> msg,
NetworkNode networkNode)
Sending method for bucket request messages.
|
SplitResult |
NetworkBucketDispatcher.splitBucket(RemoteBucket remoteBucket,
SplitPolicy policy,
int whoStays)
Splits a given bucket on the remote node creating the new buckets in situ.
|
Constructor and Description |
---|
BucketExceptionReplyMessage(BucketRequestMessage<?> message,
BucketStorageException bucketException)
Creates a new instance of BucketExceptionReplyMessage for a given bucket storage exception.
|
Modifier and Type | Method and Description |
---|---|
LocalBucket |
ReplicationNetworkBucketDispatcher.addBucket(LocalBucket bucket)
Add new bucket with encapsulation into ReplicationBucket
|
void |
ReplicationBucket.addObject(LocalAbstractObject object) |
int |
ReplicationBucket.addObjects(java.util.Collection<? extends LocalAbstractObject> objects) |
int |
ReplicationBucket.addObjects(java.util.Iterator<? extends LocalAbstractObject> objects) |
void |
ReplicationBucket.createReplica(NetworkNode atNetworkNode) |
void |
ReplicationNetworkBucketDispatcher.createReplica(NetworkNode atNetworkNode)
Methods to be executed on the replication buckets
|
Modifier and Type | Method and Description |
---|---|
void |
MetaObjectProfiSCT.DatabaseSupport.removeObject(int objectId)
Remove the object from the database storage.
|
int |
MetaObjectProfiSCT.DatabaseSupport.storeObject(MetaObjectProfiSCT object)
Store the object into the database storage.
|
void |
MetaObjectProfiSCT.DatabaseSupport.updateObject(int objectId,
MetaObjectProfiSCT object)
Updates the object stored in the database storage.
|