| Modifier and Type | Method and Description |
|---|---|
void |
PersistingElement.activate(String... families)
Retrieves information from the store and put it into this persisting element.
|
void |
PersistingElement.activateColumnFamily(String name)
Activates a given column family (does not activate included persisting elements).
|
void |
PersistingElement.activateColumnFamily(String name,
Object from,
Object to)
Activates a given column family (does not activate included persisting elements).
|
void |
PersistingElement.activateColumnFamilyIfNotAlready(String name)
Activates a given column family (does not activate included persisting elements) in case it was not done before (with any possible activation method).
|
void |
PersistingElement.activateColumnFamilyIfNotAlready(String name,
long lastActivationTimeoutMs)
Activates a given column family (does not activate included persisting elements) in case it was not done before (with any possible activation method).
|
void |
PersistingElement.activateColumnFamilyIfNotAlready(String name,
long lastActivationTimeoutMs,
Object from,
Object to)
Activates a given column family (does not activate included persisting elements) in case it was not done before (with any possible activation method).
|
void |
PersistingElement.activateColumnFamilyIfNotAlready(String name,
Object from,
Object to)
Activates a given column family (does not activate included persisting elements) in case it was not done before (with any possible activation method).
|
void |
PersistingElement.activateIfNotAlready(long lastActivationTimeoutMs,
String... families)
Retrieves information that have not been activated yet from the store and put it into this persisting element.
|
void |
PersistingElement.activateIfNotAlready(String... families)
Retrieves information that have not been activated yet from the store and put it into this persisting element.
|
void |
PersistingElement.delete()
Deletes rows representing this persisting element in the store.
|
void |
PersistingElement.deleteNoCache()
Deletes rows representing this persisting element in the store.
|
boolean |
PersistingElement.exists()
Checks whether the row representing this persisting element is known to exist in the store avoiding as much as possible to query the data store.
|
boolean |
PersistingElement.existsInStore()
Checks whether the row representing this persisting element exists in the store.
|
void |
PersistingElement.store()
Stores the object into the data store designated by
PersistingElement.getStore(). |
void |
PersistingElement.storeNoCache()
Store this persisting element as
PersistingElement.store() but ignoring any write cache. |
| Modifier and Type | Method and Description |
|---|---|
void |
CachedStore.delete(MetaInformation meta,
String table,
String id) |
boolean |
CachedStore.exists(MetaInformation meta,
String table,
String row) |
boolean |
CachedStore.exists(MetaInformation meta,
String table,
String row,
String family)
check if an element exist in the cache
|
Row.ColumnFamilyData |
CachedStore.get(MetaInformation meta,
String table,
String id,
Set<String> families) |
Map<String,byte[]> |
CachedStore.get(MetaInformation meta,
String table,
String id,
String family) |
void |
CachedStore.start() |
| Modifier and Type | Method and Description |
|---|---|
void |
WriteRetentionStore.delete(MetaInformation meta,
String table,
String id) |
void |
WriteRetentionStore.start() |
void |
WriteRetentionStore.storeChanges(MetaInformation meta,
String table,
String id,
Row.ColumnFamilyData changed,
Map<String,Set<String>> removed,
Map<String,Map<String,Number>> increments) |
| Modifier and Type | Method and Description |
|---|---|
void |
ColumnFamily.activate() |
void |
ColumnFamily.activate(Constraint c) |
void |
SetColumnFamily.activate(Object from,
Object to) |
void |
MapColumnFamily.activate(Object from,
Object to) |
abstract void |
ColumnFamily.activate(Object from,
Object to) |
void |
ColumnFamily.activate(String fromIndex,
String toIndex) |
boolean |
SetColumnFamily.containsInStore(Object o)
Checks whether this element exists in the family.
|
T |
ColumnFamily.getFromStore(String key)
Finds an element according to its key.
|
boolean |
ColumnFamily.isEmptyInStore()
Checks whether this column family is empty in the data store.
|
void |
ColumnFamily.rebuild(Map<String,byte[]> rawData) |
| Modifier and Type | Method and Description |
|---|---|
long |
Memory.count(String table,
Constraint c) |
boolean |
Memory.exists(String table,
String row) |
boolean |
Memory.exists(String table,
String row,
String family) |
CloseableKeyIterator |
Memory.get(String table,
Constraint c,
int limit,
Set<String> families) |
Row.ColumnFamilyData |
Memory.get(String table,
String id,
Set<String> families) |
Map<String,byte[]> |
Memory.get(String table,
String id,
String family,
Constraint c) |
boolean |
Memory.hasTable(String tableName) |
| Modifier and Type | Method and Description |
|---|---|
static long |
ImportExport.importPersistingElements(InputStream fis)
Import a serialized set in a InputStream.
|
static long |
ImportExport.importPersistingElements(String file)
Import a serialized set from a file.
|
static <AE extends PersistingElement,E extends AE> |
Process.processElements(Class<E> clazz,
Constraint c,
Process<AE> processAction,
int limit,
String[] families,
int threadNumber,
ProcessCanceller cancel,
ExecutorService executor) |
static <AE extends PersistingElement,E extends AE> |
Process.processElementsRemotely(Class<E> clazz,
Constraint c,
Process<AE> process,
Callback callback,
int limit,
String[] families,
int threadNumber,
long timeout) |
static <T extends PersistingElement> |
ImportExport.readSerializedPersistingElements(InputStream fis,
Process<T> process)
Processes sequentially each element of a serialized stream without importing them.
|
static long |
ImportExport.readSerializedPersistingElements(String file,
Process<? extends PersistingElement> process)
Processes sequentially each element of a serialized file without importing them.
|
| Modifier and Type | Method and Description |
|---|---|
T |
SearchableClassConstraintBuilder.any()
Runs the query to find an element matching the query.
|
long |
SearchableClassConstraintBuilder.count()
Runs the query to find the number of matching elements.
|
long |
SearchableClassConstraintBuilder.exportTo(ObjectOutputStream out)
Runs the query to find at most N matching elements and serialize a representation into the output stream.
|
long |
SearchableClassConstraintBuilder.exportTo(String file)
Runs the query to find at most N matching elements and serialize a representation into the output stream.
|
Process.ProcessReport<T> |
SearchableClassConstraintBuilder.forEach(Process<T> action)
Performs an action for each element corresponding to the query.
|
Process.ProcessReport<T> |
SearchableClassConstraintBuilder.forEach(Process<T> action,
int threadNumber,
long timeoutMs)
Performs an action for each element corresponding to the query using parallel threads.
|
Process.ProcessReport<T> |
SearchableClassConstraintBuilder.forEach(Process<T> action,
int threadNumber,
long timeoutMs,
ExecutorService executor)
Performs an action for each element corresponding to the query using parallel threads ; method might return before process is ended.
|
Process.ProcessReport<T> |
SearchableClassConstraintBuilder.forEach(Process<T> action,
int threadNumber,
ProcessCanceller canceller)
Performs an action for each element corresponding to the query using parallel threads.
|
Process.ProcessReport<T> |
SearchableClassConstraintBuilder.forEach(Process<T> action,
int threadNumber,
ProcessCanceller canceller,
ExecutorService executor)
Performs an action for each element corresponding to the query using parallel threads ; method might return before process is ended.
|
NavigableSet<T> |
SearchableClassConstraintBuilder.go()
Runs the query to find at most N matching elements.
|
CloseableIterator<T> |
SearchableClassConstraintBuilder.iterate()
Runs the query to find at most N matching elements.
|
void |
SearchableClassConstraintBuilder.remoteForEach(Process<T> action,
Callback callBack,
int threadNumber,
long timeout)
Performs asynchronously an action for each element corresponding to the query.
|
T |
SearchableClassConstraintBuilder.withId(String id)
Finds the element with the given id.
|
| Modifier and Type | Method and Description |
|---|---|
long |
Store.count(MetaInformation meta,
String table,
Constraint c)
Counts the number of element satisfying the constraint.
|
long |
SimpleStoreWrapper.count(MetaInformation meta,
String table,
Constraint c) |
long |
DelegatingStore.count(MetaInformation meta,
String table,
Constraint c) |
long |
SimpleStore.count(String table,
Constraint c)
Counts the number of element satisfying the constraint.
|
void |
Store.delete(MetaInformation meta,
String table,
String id)
Deletes a particular element.
|
void |
SimpleStoreWrapper.delete(MetaInformation meta,
String table,
String id) |
void |
DelegatingStore.delete(MetaInformation meta,
String table,
String id) |
void |
SimpleStore.delete(String table,
String id)
Deletes the given row
|
boolean |
Store.exists(MetaInformation meta,
String table,
String row)
Tests for a row.
|
boolean |
SimpleStoreWrapper.exists(MetaInformation meta,
String table,
String row) |
boolean |
DelegatingStore.exists(MetaInformation meta,
String table,
String row) |
boolean |
Store.exists(MetaInformation meta,
String table,
String row,
String family)
Tests whether a column family is empty.
|
boolean |
SimpleStoreWrapper.exists(MetaInformation meta,
String table,
String row,
String family) |
boolean |
DelegatingStore.exists(MetaInformation meta,
String table,
String row,
String family) |
boolean |
SimpleStore.exists(String table,
String row)
Tests for a row.
|
boolean |
SimpleStore.exists(String table,
String row,
String family)
Tests whether a column family is empty.
|
CloseableKeyIterator |
Store.get(MetaInformation meta,
String table,
Constraint c,
int limit,
Set<String> families)
Rows matching constraint sorted according to their key in ascending
order.
|
CloseableKeyIterator |
SimpleStoreWrapper.get(MetaInformation meta,
String table,
Constraint c,
int limit,
Set<String> families) |
CloseableKeyIterator |
DelegatingStore.get(MetaInformation meta,
String table,
Constraint c,
int limit,
Set<String> families) |
Row.ColumnFamilyData |
Store.get(MetaInformation meta,
String table,
String id,
Set<String> families)
Returns all elements in families ; no side-effect.
|
Row.ColumnFamilyData |
SimpleStoreWrapper.get(MetaInformation meta,
String table,
String id,
Set<String> families) |
Row.ColumnFamilyData |
DelegatingStore.get(MetaInformation meta,
String table,
String id,
Set<String> families) |
Map<String,byte[]> |
Store.get(MetaInformation meta,
String table,
String id,
String family)
Returns all elements in a family ; no side-effect.
|
Map<String,byte[]> |
SimpleStoreWrapper.get(MetaInformation meta,
String table,
String id,
String family) |
Map<String,byte[]> |
DelegatingStore.get(MetaInformation meta,
String table,
String id,
String family) |
Map<String,byte[]> |
Store.get(MetaInformation meta,
String table,
String id,
String family,
Constraint c)
Returns all elements in a family ; no side-effect.
|
Map<String,byte[]> |
SimpleStoreWrapper.get(MetaInformation meta,
String table,
String id,
String family,
Constraint c) |
Map<String,byte[]> |
DelegatingStore.get(MetaInformation meta,
String table,
String id,
String family,
Constraint c) |
byte[] |
Store.get(MetaInformation meta,
String table,
String row,
String family,
String key)
Returns an element from a family.
|
byte[] |
SimpleStoreWrapper.get(MetaInformation meta,
String table,
String row,
String family,
String key) |
byte[] |
DelegatingStore.get(MetaInformation meta,
String table,
String row,
String family,
String key) |
CloseableKeyIterator |
SimpleStore.get(String table,
Constraint c,
int limit,
Set<String> families)
Rows matching constraint sorted according to their key in ascending order.
|
Row.ColumnFamilyData |
SimpleStore.get(String table,
String id,
Set<String> families)
Returns all elements in families ; no side-effect.
|
Map<String,byte[]> |
SimpleStore.get(String table,
String id,
String family)
Returns all elements in a family ; no side-effect.
|
Map<String,byte[]> |
SimpleStore.get(String table,
String id,
String family,
Constraint c)
Returns all elements in a family ; no side-effect.
|
byte[] |
SimpleStore.get(String table,
String row,
String family,
String key)
Returns an element from a family.
|
boolean |
Store.hasTable(String tableName)
Checks whether the given table exists in this store.
|
boolean |
SimpleStoreWrapper.hasTable(String tableName) |
boolean |
SimpleStore.hasTable(String tableName)
Checks whether the given table exists in this store.
|
boolean |
DelegatingStore.hasTable(String tableName) |
<AE extends PersistingElement,E extends AE> |
ActionnableStore.process(MetaInformation meta,
String table,
Constraint c,
Set<String> families,
Class<E> element,
Process<AE> action,
Callback callback) |
void |
Store.start()
Called once the store is created ; only one store is instanciated with
the same properties.
|
void |
SimpleStoreWrapper.start() |
void |
SimpleStore.start()
Called once the store is created ; only one store is instanciated with the same properties.
|
void |
DelegatingStore.start() |
void |
Store.storeChanges(MetaInformation meta,
String table,
String id,
Row.ColumnFamilyData changed,
Map<String,Set<String>> removed,
Map<String,Map<String,Number>> increments)
Stores given piece of information.
|
void |
SimpleStoreWrapper.storeChanges(MetaInformation meta,
String table,
String id,
Row.ColumnFamilyData changed,
Map<String,Set<String>> removed,
Map<String,Map<String,Number>> increments) |
void |
DelegatingStore.storeChanges(MetaInformation meta,
String table,
String id,
Row.ColumnFamilyData changed,
Map<String,Set<String>> removed,
Map<String,Map<String,Number>> increments) |
void |
SimpleStore.storeChanges(String table,
String id,
Row.ColumnFamilyData changed,
Map<String,Set<String>> removed,
Map<String,Map<String,Number>> increments)
Stores given piece of information.
|
Copyright © 2016. All Rights Reserved.