public class MavibotTable<K,V> extends AbstractTable<K,V>
Modifier and Type | Field and Description |
---|---|
protected org.apache.directory.mavibot.btree.RecordManager |
recordMan
The used recordManager
|
allowsDuplicates, commitNumber, count, keyComparator, name, schemaManager, valueComparator
Constructor and Description |
---|
MavibotTable(org.apache.directory.mavibot.btree.RecordManager recordMan,
org.apache.directory.api.ldap.model.schema.SchemaManager schemaManager,
String name,
org.apache.directory.mavibot.btree.serializer.ElementSerializer<K> keySerializer,
org.apache.directory.mavibot.btree.serializer.ElementSerializer<V> valueSerializer,
boolean allowDuplicates)
Creates a new instance of MavibotTable.
|
MavibotTable(org.apache.directory.mavibot.btree.RecordManager recordMan,
org.apache.directory.api.ldap.model.schema.SchemaManager schemaManager,
String name,
org.apache.directory.mavibot.btree.serializer.ElementSerializer<K> keySerializer,
org.apache.directory.mavibot.btree.serializer.ElementSerializer<V> valueSerializer,
boolean allowDuplicates,
int cacheSize)
Creates a new instance of MavibotTable.
|
Modifier and Type | Method and Description |
---|---|
void |
close(PartitionTxn transaction)
Closes the underlying Db of this Table.
|
long |
count(PartitionTxn transaction,
K key)
Gets the count of the number of records in this Table with a specific
key: returns the number of duplicates for a key.
|
org.apache.directory.api.ldap.model.cursor.Cursor<org.apache.directory.api.ldap.model.cursor.Tuple<K,V>> |
cursor()
Creates a Cursor that traverses Tuples in a Table.
|
org.apache.directory.api.ldap.model.cursor.Cursor<org.apache.directory.api.ldap.model.cursor.Tuple<K,V>> |
cursor(PartitionTxn partitionTxn,
K key)
Creates a Cursor that traverses Table Tuples for the same key.
|
V |
get(PartitionTxn transaction,
K key)
Gets the value of a record by key if the key exists.
|
protected org.apache.directory.mavibot.btree.BTree<K,V> |
getBTree() |
ArrayTree<V> |
getDupsContainer(byte[] serialized) |
boolean |
has(PartitionTxn partitionTxn,
K key)
Checks to see if this table has one or more tuples with a specific key:
this is exactly the same as a get call with a check to see if the
returned value is null or not.
|
boolean |
has(PartitionTxn transaction,
K key,
V value)
Checks to see if this table has a key with a specific value.
|
boolean |
hasGreaterOrEqual(PartitionTxn transaction,
K key)
Checks to see if this table has a record with a key greater than or
equal to the key argument.
|
boolean |
hasGreaterOrEqual(PartitionTxn transaction,
K key,
V val)
Checks to see if this table has a Tuple with a key equal to the key
argument, yet with a value greater than or equal to the value argument
provided.
|
boolean |
hasLessOrEqual(PartitionTxn transaction,
K key)
Checks to see if this table has a record with a key less than or
equal to the key argument.
|
boolean |
hasLessOrEqual(PartitionTxn partitionTxn,
K key,
V val)
Checks to see if this table has a Tuple with a key equal to the key
argument, yet with a value less than or equal to the value argument
provided.
|
void |
put(PartitionTxn partitionTxn,
K key,
V value)
Puts a record into this Table.
|
void |
remove(PartitionTxn partitionTxn,
K key)
Removes all records with a specified key from this Table.
|
void |
remove(PartitionTxn partitionTxn,
K key,
V value)
Removes a single key value pair with a specified key and value from
this Table.
|
void |
sync()
Synchronizes the buffers with disk.
|
String |
toString() |
org.apache.directory.api.ldap.model.cursor.Cursor<V> |
valueCursor(PartitionTxn transaction,
K key)
Creates a Cursor that traverses Table values for the same key.
|
count, getKeyComparator, getName, getValueComparator, greaterThanCount, isDupsEnabled, lessThanCount
protected org.apache.directory.mavibot.btree.RecordManager recordMan
public MavibotTable(org.apache.directory.mavibot.btree.RecordManager recordMan, org.apache.directory.api.ldap.model.schema.SchemaManager schemaManager, String name, org.apache.directory.mavibot.btree.serializer.ElementSerializer<K> keySerializer, org.apache.directory.mavibot.btree.serializer.ElementSerializer<V> valueSerializer, boolean allowDuplicates) throws IOException
recordMan
- The associated RecordManagerschemaManager
- The SchemaManagername
- The Table namekeySerializer
- The Key serializervalueSerializer
- The Value serializerallowDuplicates
- If the table allows duplicate valuesIOException
- If the instance creation failedpublic MavibotTable(org.apache.directory.mavibot.btree.RecordManager recordMan, org.apache.directory.api.ldap.model.schema.SchemaManager schemaManager, String name, org.apache.directory.mavibot.btree.serializer.ElementSerializer<K> keySerializer, org.apache.directory.mavibot.btree.serializer.ElementSerializer<V> valueSerializer, boolean allowDuplicates, int cacheSize) throws IOException
recordMan
- The associated RecordManagerschemaManager
- The SchemaManagername
- The Table namekeySerializer
- The Key serializervalueSerializer
- The Value serializerallowDuplicates
- If the table allows duplicate valuescacheSize
- The cache size to useIOException
- If the instance creation failedpublic boolean has(PartitionTxn partitionTxn, K key) throws org.apache.directory.api.ldap.model.exception.LdapException
partitionTxn
- The transaction we are running inkey
- the Object of the key to check fororg.apache.directory.api.ldap.model.exception.LdapException
- if there is a failure to read the underlying Dbpublic boolean has(PartitionTxn transaction, K key, V value) throws org.apache.directory.api.ldap.model.exception.LdapException
transaction
- The transaction we are running inkey
- the key to check forvalue
- the value to check fororg.apache.directory.api.ldap.model.exception.LdapException
- if there is a failure to read the underlying Dbpublic boolean hasGreaterOrEqual(PartitionTxn transaction, K key) throws org.apache.directory.api.ldap.model.exception.LdapException
transaction
- The transaction we are running inkey
- the key to compare keys toorg.apache.directory.api.ldap.model.exception.LdapException
- if there is a failure to read the underlying Dbpublic boolean hasLessOrEqual(PartitionTxn transaction, K key) throws org.apache.directory.api.ldap.model.exception.LdapException
transaction
- The transaction we are running inkey
- the key to compare keys toorg.apache.directory.api.ldap.model.exception.LdapException
- if there is a failure to read the underlying Dbpublic boolean hasGreaterOrEqual(PartitionTxn transaction, K key, V val) throws org.apache.directory.api.ldap.model.exception.LdapException
transaction
- The transaction we are running inkey
- the keyval
- the value to compare values toorg.apache.directory.api.ldap.model.exception.LdapException
- if there is a failure to read the underlying Db
or if the underlying Db is not of the Btree type that allows sorted
duplicate values.public boolean hasLessOrEqual(PartitionTxn partitionTxn, K key, V val) throws org.apache.directory.api.ldap.model.exception.LdapException
partitionTxn
- The transaction we are running inkey
- the keyval
- the value to compare values toorg.apache.directory.api.ldap.model.exception.LdapException
- if there is a failure to read the underlying Db
or if the underlying Db is not of the Btree type that allows sorted
duplicate values.public V get(PartitionTxn transaction, K key) throws org.apache.directory.api.ldap.model.exception.LdapException
transaction
- The transaction we are running inkey
- the key of the recordorg.apache.directory.api.ldap.model.exception.LdapException
- if there is a failure to read the underlying Dbpublic void put(PartitionTxn partitionTxn, K key, V value) throws org.apache.directory.api.ldap.model.exception.LdapException
partitionTxn
- The transaction we are running inkey
- the key of the recordvalue
- the value of the record.org.apache.directory.api.ldap.model.exception.LdapException
- if there is a failure to read or write to the
underlying Dbpublic void remove(PartitionTxn partitionTxn, K key) throws org.apache.directory.api.ldap.model.exception.LdapException
partitionTxn
- The transaction we are running inkey
- the key of the records to removeorg.apache.directory.api.ldap.model.exception.LdapException
- if there is a failure to read or write to
the underlying Dbpublic void remove(PartitionTxn partitionTxn, K key, V value) throws org.apache.directory.api.ldap.model.exception.LdapException
partitionTxn
- The transaction we are running inkey
- the key of the record to removevalue
- the value of the record to removeorg.apache.directory.api.ldap.model.exception.LdapException
- if there is a failure to read or write to
the underlying Dbpublic org.apache.directory.api.ldap.model.cursor.Cursor<org.apache.directory.api.ldap.model.cursor.Tuple<K,V>> cursor()
public org.apache.directory.api.ldap.model.cursor.Cursor<org.apache.directory.api.ldap.model.cursor.Tuple<K,V>> cursor(PartitionTxn partitionTxn, K key) throws org.apache.directory.api.ldap.model.exception.LdapException
partitionTxn
- The transaction we are running inkey
- the duplicate key to return the Tuples oforg.apache.directory.api.ldap.model.exception.LdapException
- if there are failures accessing underlying storespublic org.apache.directory.api.ldap.model.cursor.Cursor<V> valueCursor(PartitionTxn transaction, K key) throws org.apache.directory.api.ldap.model.exception.LdapException
transaction
- The transaction we are running inkey
- the duplicate key to return the values oforg.apache.directory.api.ldap.model.exception.LdapException
- if there are failures accessing underlying storespublic void close(PartitionTxn transaction) throws org.apache.directory.api.ldap.model.exception.LdapException
transaction
- The transaction we are running inorg.apache.directory.api.ldap.model.exception.LdapException
- on any failurespublic long count(PartitionTxn transaction, K key) throws org.apache.directory.api.ldap.model.exception.LdapException
transaction
- The transaction we are running inkey
- the Object key to count.org.apache.directory.api.ldap.model.exception.LdapException
- if there is a failure to read the underlying Dbpublic ArrayTree<V> getDupsContainer(byte[] serialized) throws IOException
IOException
protected org.apache.directory.mavibot.btree.BTree<K,V> getBTree()
public void sync() throws IOException
IOException
- if errors are encountered on the flushpublic String toString()
toString
in class AbstractTable<K,V>
Object.toString()
Copyright © 2003–2020 The Apache Software Foundation. All rights reserved.