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.split |
Bucket splitting support.
|
messif.netbucket |
Networked objects and buckets.
|
messif.netbucket.replication |
Replication support for remote buckets.
|
messif.operations.query |
Implementation of data querying operations.
|
messif.pivotselection |
Support for selection of representative objects (pivots).
|
Modifier and Type | Field and Description |
---|---|
protected LocalBucket |
SequentialScan.bucket
One instance of bucket where all objects are stored
|
Constructor and Description |
---|
SequentialScan(LocalBucket bucket)
Creates a new instance of SequantialScan access structure with the given bucket.
|
SequentialScan(LocalBucket bucket,
AbstractObjectIterator<LocalAbstractObject> pivotIter,
int pivotCount,
boolean pivotDistsValidIfGiven)
Creates a new instance of SequantialScan access structure with the given bucket and filtering pivots.
|
Constructor and Description |
---|
ParallelSequentialScan(int parallelization,
java.lang.Class<? extends LocalBucket> bucketClass)
Creates a new instance of ParallelSequentialScan access structure with specific bucket class.
|
ParallelSequentialScan(int parallelization,
java.lang.Class<? extends LocalBucket> bucketClass,
java.util.Map<java.lang.String,java.lang.Object> bucketClassParams)
Creates a new instance of ParallelSequentialScan access structure with specific bucket class.
|
SequentialScan(java.lang.Class<? extends LocalBucket> bucketClass)
Creates a new instance of SequantialScan access structure with specific bucket class.
|
SequentialScan(java.lang.Class<? extends LocalBucket> bucketClass,
AbstractObjectIterator<LocalAbstractObject> pivotIter,
int pivotCount,
boolean pivotDistsValidIfGiven)
Creates a new instance of SequantialScan access structure with specific bucket class and filtering pivots.
|
SequentialScan(java.lang.Class<? extends LocalBucket> bucketClass,
java.util.Map<java.lang.String,java.lang.Object> bucketClassParams)
Creates a new instance of SequantialScan access structure with specific bucket class.
|
SequentialScan(java.lang.Class<? extends LocalBucket> bucketClass,
java.util.Map<java.lang.String,java.lang.Object> bucketClassParams,
AbstractObjectIterator<LocalAbstractObject> pivotIter,
int pivotCount,
boolean pivotDistsValidIfGiven)
Creates a new instance of SequantialScan access structure with specific bucket class and filtering pivots.
|
Modifier and Type | Class and Description |
---|---|
class |
OrderedLocalBucket<C>
An extension of
LocalBucket that maintains the stored objects in
a certain order. |
Modifier and Type | Method and Description |
---|---|
LocalBucket |
BucketDispatcher.addBucket(LocalBucket bucket)
Add an existing bucket to this dispatcher.
|
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.
|
static LocalBucket |
BucketDispatcher.createBucket(java.lang.Class<? extends LocalBucket> storageClass,
long capacity,
long softCapacity,
long lowOccupation,
boolean occupationAsBytes,
java.util.Map<java.lang.String,java.lang.Object> storageClassParams)
Create new local bucket with specified storage class and storage capacity (different from default values).
|
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.
|
LocalBucket |
BucketDispatcher.getBucket(int bucketID)
Returns the bucket with the specified ID.
|
LocalBucket |
BucketDispatcher.moveBucket(int bucketID,
BucketDispatcher targetDispatcher)
Move the bucket with the specified ID to another dispatcher.
|
LocalBucket |
BucketDispatcher.removeBucket(int bucketID,
boolean destroyBucket)
Delete the bucket with specified ID from this dispatcher.
|
Modifier and Type | Method and Description |
---|---|
java.util.Collection<LocalBucket> |
BucketDispatcher.getAllBuckets()
Returns the collection of all buckets maintained by this dispatcher.
|
java.lang.Class<? extends LocalBucket> |
BucketDispatcher.getDefaultBucketClass()
Returns the default class for newly created buckets.
|
Modifier and Type | Method and Description |
---|---|
LocalBucket |
BucketDispatcher.addBucket(LocalBucket bucket)
Add an existing bucket to this dispatcher.
|
protected AbstractPivotChooser |
BucketDispatcher.createAutoPivotChooser(LocalBucket bucket)
Creates a new pivot chooser for the provided bucket.
|
void |
BucketFilterAfterAdd.filterAfterAdd(LocalAbstractObject object,
LocalBucket bucket)
Filter object after its insertion into a bucket.
|
void |
BucketFilterAfterRemove.filterAfterRemove(LocalAbstractObject object,
LocalBucket bucket)
Filter object after its removal from a bucket.
|
void |
BucketFilterBeforeAdd.filterBeforeAdd(LocalAbstractObject object,
LocalBucket bucket)
Filter object before its insertion into a bucket.
|
void |
BucketFilterBeforeRemove.filterBeforeRemove(LocalAbstractObject object,
LocalBucket bucket)
Filter object before its removal from a bucket.
|
Modifier and Type | Method and Description |
---|---|
LocalBucket |
BucketDispatcher.createBucket(java.lang.Class<? extends LocalBucket> storageClass)
Create new local bucket with specified storage class and default storage capacity.
|
static LocalBucket |
BucketDispatcher.createBucket(java.lang.Class<? extends LocalBucket> storageClass,
long capacity,
long softCapacity,
long lowOccupation,
boolean occupationAsBytes,
java.util.Map<java.lang.String,java.lang.Object> storageClassParams)
Create new local bucket with specified storage class and storage capacity (different from default values).
|
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).
|
void |
BucketDispatcher.setDefaultBucketClass(java.lang.Class<? extends LocalBucket> defaultBucketClass)
Set default class for all new buckets
|
Constructor and Description |
---|
BucketDispatcher(int maxBuckets,
long bucketCapacity,
java.lang.Class<? extends LocalBucket> defaultBucketClass)
Creates a new instance of BucketDispatcher only with maximal capacity specification.
|
BucketDispatcher(int maxBuckets,
long bucketCapacity,
long bucketSoftCapacity,
long bucketLowOccupation,
boolean bucketOccupationAsBytes,
java.lang.Class<? extends LocalBucket> defaultBucketClass)
Creates a new instance of BucketDispatcher with full specification of default values.
|
BucketDispatcher(int maxBuckets,
long bucketCapacity,
long bucketSoftCapacity,
long bucketLowOccupation,
boolean bucketOccupationAsBytes,
java.lang.Class<? extends LocalBucket> defaultBucketClass,
java.util.Map<java.lang.String,java.lang.Object> defaultBucketClassParams)
Creates a new instance of BucketDispatcher with full specification of default values.
|
Modifier and Type | Class and Description |
---|---|
class |
AlgorithmStorageBucket
This is a LocalBucket that allows to create buckets backed by an Algorithm.
|
class |
DiskBlockBucket
A disk-oriented implementation of
LocalBucket . |
class |
DiskBlockLocatorBucket
A disk-oriented implementation of
LocalBucket with an indexed access using locators. |
class |
DiskBlockObjectKeyBucket
A disk-oriented implementation of
LocalBucket with an indexed access using object keys . |
class |
DiskBlockObjectKeyMemoryBucket
A disk-oriented implementation of
LocalBucket . |
class |
MemoryStorageBucket
A volatile implementation of
LocalBucket . |
class |
MemoryStorageLocatorBucket
A volatile implementation of
LocalBucket . |
class |
MemoryStorageNoDupsBucket
A volatile implementation of
LocalBucket . |
class |
MemoryStorageObjectKeyBucket
A volatile implementation of
LocalBucket . |
class |
PlainStorageBucket
Encapsulating bucket for a plain storage.
|
class |
VirtualStorageBucket<C>
Encapsulating bucket for generic indices and storages.
|
Modifier and Type | Field and Description |
---|---|
protected LocalBucket |
BucketBallRegion.bucket
The bucket on which this ball region should be maintained
|
Modifier and Type | Method and Description |
---|---|
LocalBucket |
BucketBallRegion.getBucket()
Returns the bucket associated with this ball region.
|
Modifier and Type | Method and Description |
---|---|
void |
BucketBallRegion.filterAfterAdd(LocalAbstractObject object,
LocalBucket bucket)
Adjust this ball region whenever an object is inserted into a bucket.
|
void |
BucketBallRegion.filterAfterRemove(LocalAbstractObject object,
LocalBucket bucket) |
protected BucketBallRegion |
SplitPolicy.getBucketBallRegion(LocalBucket bucket)
Returns the
BucketBallRegion associated with the specified bucket. |
int |
SplitPolicy.match(LocalBucket bucket)
Returns the group (partition) to which the whole bucket belongs.
|
Constructor and Description |
---|
BucketBallRegion(LocalBucket bucket)
Creates a new instance of BucketBallRegion.
|
BucketBallRegion(LocalBucket bucket,
boolean registerAsFilter)
Creates a new instance of BucketBallRegion.
|
BucketBallRegion(LocalBucket bucket,
boolean registerAsFilter,
LocalAbstractObject pivot)
Creates a new instance of BucketBallRegion.
|
BucketBallRegion(LocalBucket bucket,
boolean registerAsFilter,
LocalAbstractObject pivot,
float radius)
Creates a new instance of BucketBallRegion with specified pivot and radius.
|
Modifier and Type | Method and Description |
---|---|
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.
|
Constructor and Description |
---|
RemoteBucket(NetworkBucketDispatcher netbucketDisp,
LocalBucket bucket)
Creates a new instance of RemoteBucket from LocalBucket.
|
Constructor and Description |
---|
BucketCreateRequestMessage(boolean useParameters,
java.lang.Class<? extends LocalBucket> storageClass,
java.util.Map<java.lang.String,java.lang.Object> storageClassParams,
long capacity,
long softCapacity)
Internal constructor setting all the parameters.
|
BucketCreateRequestMessage(java.lang.Class<? extends LocalBucket> storageClass,
java.util.Map<java.lang.String,java.lang.Object> storageClassParams,
long capacity,
long softCapacity)
If this constructor is used, a bucket given parameters is created.
|
NetworkBucketDispatcher(MessageDispatcher messageDisp,
int maxBuckets,
long bucketCapacity,
java.lang.Class<? extends LocalBucket> defaultBucketClass)
Creates a new instance of NetworkBucketDispatcher only with a maximal capacity specification.
|
NetworkBucketDispatcher(MessageDispatcher messageDisp,
int maxBuckets,
long bucketCapacity,
long bucketSoftCapacity,
long bucketLowOccupation,
boolean bucketOccupationAsBytes,
java.lang.Class<? extends LocalBucket> defaultBucketClass)
Creates a new instance of NetworkBucketDispatcher with full specification of default values.
|
NetworkBucketDispatcher(MessageDispatcher messageDisp,
int maxBuckets,
long bucketCapacity,
long bucketSoftCapacity,
long bucketLowOccupation,
boolean bucketOccupationAsBytes,
java.lang.Class<? extends LocalBucket> defaultBucketClass,
java.util.Map<java.lang.String,java.lang.Object> defaultBucketClassParams)
Creates a new instance of NetworkBucketDispatcher with full specification of default values.
|
Modifier and Type | Class and Description |
---|---|
class |
ReplicationBucket |
Modifier and Type | Field and Description |
---|---|
protected LocalBucket |
ReplicationBucket.encapsulatedBucket |
Modifier and Type | Method and Description |
---|---|
LocalBucket |
ReplicationNetworkBucketDispatcher.addBucket(LocalBucket bucket)
Add new bucket with encapsulation into ReplicationBucket
|
Modifier and Type | Method and Description |
---|---|
LocalBucket |
ReplicationNetworkBucketDispatcher.addBucket(LocalBucket bucket)
Add new bucket with encapsulation into ReplicationBucket
|
Constructor and Description |
---|
ReplicationBucket(ReplicationNetworkBucketDispatcher bucketDispatcher,
LocalBucket encapsulatedBucket)
Creates a new instance of ReplicationBucket
|
Constructor and Description |
---|
ReplicationNetworkBucketDispatcher(MessageDispatcher messageDisp,
int maxBuckets,
long bucketCapacity,
boolean replicateBucketsEqually,
java.lang.Class<? extends LocalBucket> defaultBucketClass)
Creates a new instance of ReplicationNetworkBucketDispatcher
|
ReplicationNetworkBucketDispatcher(MessageDispatcher messageDisp,
int maxBuckets,
long bucketCapacity,
long bucketSoftCapacity,
long bucketLowOccupation,
boolean bucketOccupationAsBytes,
java.lang.Class<? extends LocalBucket> defaultBucketClass,
boolean replicateBucketsEqually)
Creates a new instance of ReplicationNetworkBucketDispatcher
|
Modifier and Type | Method and Description |
---|---|
int |
GetObjectCountOperation.evaluate(LocalBucket bucket)
Evaluate this query on a given bucket.
|
Modifier and Type | Method and Description |
---|---|
void |
ClusterPivotChooser.filterAfterAdd(LocalAbstractObject object,
LocalBucket bucket) |
void |
CoveragePivotChooser.filterAfterAdd(LocalAbstractObject object,
LocalBucket bucket) |
void |
IncrementalPivotChooser.filterAfterAdd(LocalAbstractObject object,
LocalBucket bucket) |
void |
OnFlyRandomPivotChooser.filterAfterAdd(LocalAbstractObject object,
LocalBucket bucket)
filterObject()
Filter method used to pick one pivot at random.
|
void |
OutlierPivotChooser.filterAfterAdd(LocalAbstractObject object,
LocalBucket bucket) |
void |
TwoDistantIncrementalPivotChooser.filterAfterAdd(LocalAbstractObject object,
LocalBucket bucket)
Method for preselecting pivots as they are added to a bucket.
|
void |
ClusterPivotChooser.filterAfterRemove(LocalAbstractObject object,
LocalBucket bucket) |
void |
CoveragePivotChooser.filterAfterRemove(LocalAbstractObject object,
LocalBucket bucket) |
void |
IncrementalPivotChooser.filterAfterRemove(LocalAbstractObject object,
LocalBucket bucket) |
void |
OutlierPivotChooser.filterAfterRemove(LocalAbstractObject object,
LocalBucket bucket) |