Modifier and Type | Method and Description |
---|---|
void |
AndroidDBSession.addAndSwitchInstance(String instanceId,
String path) |
void |
AndroidDBSession.addInstance(String instanceId,
String path) |
void |
AndroidDBSession.closeSession() |
EntityBag |
AndroidDBSession.createOrGetBag(String bagName) |
EntityBag |
AndroidDBSession.createOrGetBag(String instanceId,
String bagName) |
protected StorageService |
AndroidStorageServiceFactory.createStorageServiceInstance(Instance instance,
String bagName) |
Instance |
AndroidDBSession.deleteInstance(String instanceId) |
EntityBag |
AndroidDBSession.getBag(String bagName) |
EntityBag |
AndroidDBSession.getBag(String instanceId,
String bagName) |
List<EntityBag> |
AndroidDBSession.getBags() |
List<EntityBag> |
AndroidDBSession.getBags(String instanceId) |
IndexManager |
AndroidIndexManagerFactory.getIndexManager(String instanceId) |
DBInstance |
AndroidDBSession.getInstance(String instanceId) |
String |
AndroidDBSession.getInstanceId() |
List<Instance> |
AndroidDBSession.getInstances() |
UserAdministration |
AndroidDBSession.getUserAdministration() |
void |
AndroidDBSession.removeBag(String bagName) |
void |
AndroidDBSession.removeBag(String instanceId,
String bagName) |
void |
AndroidIndexManagerFactory.shutdownIndexes() |
void |
AndroidDBSession.switchInstance(String instanceId) |
Constructor and Description |
---|
AndroidDBSession(android.content.Context context) |
AndroidDBSession(android.content.Context context,
String instanceId) |
Constructor and Description |
---|
AndroidEntityBag(String dbInstance,
String bag) |
Modifier and Type | Method and Description |
---|---|
User |
LocalCredentialsProvider.addUser(String userName,
String allowedHost,
String contentKey,
String password) |
void |
UserMetadataProvider.addUser(User user) |
User |
UserManagerImpl.addUser(UserSession currentSession,
String userName,
String allowedHost,
String password) |
User |
UserManagerImpl.authenticate(Credentials credentials) |
void |
UserManagerImpl.authorize(UserSession userSession,
String object,
AccessMode mode) |
void |
LocalCredentialsProvider.deleteUser(String userName) |
void |
UserManagerImpl.deleteUser(UserSession session,
String userName) |
void |
UserMetadataProvider.delUser(String username) |
void |
SessionManagerImpl.endSession(String sessionId) |
List<UserSession> |
SessionManagerImpl.getActiveSessions() |
GrantObject |
UserManagerImpl.getGrantObject(UserSession session,
String object) |
List<GrantObject> |
UserManagerImpl.getGrantObjects(UserSession session) |
List<EncryptedGrants> |
GrantMetadataProvider.getGrants() |
EncryptedGrants |
GrantMetadataProvider.getObjectGrants(String objectName) |
UserSession |
SessionManagerImpl.getSession(String sessionId) |
User |
UserMetadataProvider.getUser(String username) |
User |
LocalCredentialsProvider.getUser(String userName,
String sourceHost,
String password) |
List<User> |
UserMetadataProvider.getUsers() |
List<String> |
LocalCredentialsProvider.getUsers() |
List<String> |
UserManagerImpl.getUsers(UserSession currentSession) |
void |
UserManagerImpl.grantUser(UserSession currentSession,
String object,
String userName,
AccessMode mode) |
boolean |
GrantMetadataProvider.hasGrant(String objectName) |
void |
LocalCredentialsProvider.initialize() |
void |
GrantMetadataProvider.persistGrant(EncryptedGrants encryptedGrants) |
void |
UserMetadataProvider.registerMetadataEntity(SimpleEntity entity,
long recordPointer) |
void |
GrantMetadataProvider.registerMetadataEntity(SimpleEntity entity,
long recordPointer) |
void |
UserManagerImpl.revoke(UserSession currentSession,
String object,
String userName) |
boolean |
SessionManagerImpl.sessionValid(String sessionId) |
UserSession |
SessionManagerImpl.startSession(Credentials credentials) |
Modifier and Type | Method and Description |
---|---|
static <T extends Annotation> |
AnnotationUtils.getAnnotation(AnnotatedElement type,
Class<T> annotationType) |
Modifier and Type | Method and Description |
---|---|
<T> List<T> |
EntityManager.findEntities(Class<T> type,
QueryBuilder builder) |
<T> List<T> |
EntityManager.findEntities(Class<T> type,
QueryBuilder builder,
int limit) |
<T> List<T> |
EntityManager.findEntities(Class<T> type,
QueryBuilder builder,
int start,
int limit) |
<T> T |
EntityManager.findEntity(Class<T> type,
String entityId)
Finds an entity by the identifier
|
EntityMetadata |
EntityMapper.getEntityMetadata(Class<?> type) |
<T> T |
EntityMapper.mapFrom(Class<T> targetType,
SimpleEntity entity) |
MapResult |
EntityMapper.mapTo(Object mappableObject) |
SimpleEntity |
EntityManager.persist(Object persistableObject)
Does a persist which can either be a create or update operation against the database.
|
void |
EntityManager.remove(Object persistableObject)
Removes the object from storage
|
Object |
EntityMapper.updateId(String id,
Object mappableObject) |
Modifier and Type | Method and Description |
---|---|
<T> List<T> |
EntityManagerImpl.findEntities(Class<T> types,
QueryBuilder builder) |
<T> List<T> |
EntityManagerImpl.findEntities(Class<T> types,
QueryBuilder builder,
int limit) |
<T> List<T> |
EntityManagerImpl.findEntities(Class<T> types,
QueryBuilder builder,
int start,
int limit) |
<T> T |
EntityManagerImpl.findEntity(Class<T> type,
String entityId) |
EntityMetadata |
AnnotationEntityMapper.getEntityMetadata(Class<?> entityClass) |
static Object |
EntityUtils.getValue(Object mappableObject,
PropertyMetadata propertyMetadata) |
static Property |
EntityUtils.map(Object mappableObject,
PropertyMetadata propertyMetadata) |
<T> T |
AnnotationEntityMapper.mapFrom(Class<T> targetType,
SimpleEntity entity) |
MapResult |
AnnotationEntityMapper.mapTo(Object mappableObject) |
SimpleEntity |
EntityManagerImpl.persist(Object persistableObject) |
void |
EntityManagerImpl.remove(Object persistableObject) |
Object |
AnnotationEntityMapper.updateId(String id,
Object mappableObject) |
Modifier and Type | Method and Description |
---|---|
static <T> TypeMapper<T> |
TypeMapperFactory.getTypeMapper(Class<T> type) |
static TypeMapper |
TypeMapperFactory.getTypeMapper(Method method) |
Modifier and Type | Method and Description |
---|---|
void |
LocalDBSession.addAndSwitchInstance(String instanceId,
String path) |
void |
LocalDBSession.addInstance(String instanceId,
String path) |
void |
LocalUserAdministration.addUser(String username,
String allowedHost,
String password) |
void |
LocalDBSession.closeSession() |
EntityBag |
LocalDBSession.createOrGetBag(String bagName) |
EntityBag |
LocalDBSession.createOrGetBag(String instanceId,
String bagName) |
DBSession |
LocalDBSessionFactory.createSession() |
DBSession |
LocalDBSessionFactory.createSession(Credentials credentials) |
DBSession |
LocalDBSessionFactory.createSession(String instance) |
DBSession |
LocalDBSessionFactory.createSession(String instance,
Credentials credentials) |
Instance |
LocalDBSession.deleteInstance(String instanceId) |
void |
LocalUserAdministration.deleteUser(String username) |
EntityBag |
LocalDBSession.getBag(String bagName) |
EntityBag |
LocalDBSession.getBag(String instanceId,
String bagName) |
List<EntityBag> |
LocalDBSession.getBags() |
List<EntityBag> |
LocalDBSession.getBags(String instanceId) |
DBInstance |
LocalDBSession.getInstance(String instanceId) |
String |
LocalDBSession.getInstanceId() |
List<Instance> |
LocalDBSession.getInstances() |
UserAdministration |
LocalDBSession.getUserAdministration() |
List<String> |
LocalUserAdministration.getUsers() |
void |
LocalUserAdministration.grant(String username,
String object,
AccessMode mode) |
void |
LocalDBSession.removeBag(String bagName) |
void |
LocalDBSession.removeBag(String instanceId,
String bagName) |
void |
LocalUserAdministration.revoke(String username,
String object) |
void |
LocalDBSession.switchInstance(String instanceId) |
Constructor and Description |
---|
LocalDBSession()
Creates a local DB session to the default instance
|
LocalDBSession(Credentials credentials)
Creates a local DB session with credentials
|
LocalDBSession(String instanceId)
Creates a local DB session bound to a specific instance
|
LocalDBSession(String instanceId,
Credentials credentials)
Creates a local DB session bound to a specific instance with given credentials
|
LocalUserAdministration(UserSession session) |
Modifier and Type | Method and Description |
---|---|
void |
DBConnectorSession.addAndSwitchInstance(String instanceId,
String path) |
void |
DBSession.addAndSwitchInstance(String instanceId,
String path)
Adds a new instance with the given path to the DB.
|
SimpleEntity |
RemoteEntityBag.addEntity(SimpleEntity entity) |
void |
DBConnectorSession.addInstance(String instanceId,
String path) |
void |
DBSession.addInstance(String instanceId,
String path)
Adds a new instance with the given path to the DB.
|
void |
RemoteUserAdministration.addUser(String username,
String allowedHost,
String password) |
void |
UserAdministration.addUser(String username,
String allowedHost,
String password)
Add a new user to the database, this user will be allowed to connected from the specified host or all hosts
if the wildcard '*' is used.
|
protected abstract void |
DBConnectorSession.authenticate(Credentials credentials) |
void |
DBConnectorSession.closeSession() |
void |
DBSession.closeSession()
Closes the session and removes used resources
|
EntityBag |
DBConnectorSession.createOrGetBag(String bagName) |
EntityBag |
DBSession.createOrGetBag(String bagName)
Creates a bag or gets an existing one if it already existed for the connected instance.
|
EntityBag |
DBConnectorSession.createOrGetBag(String instanceId,
String bagName) |
EntityBag |
DBSession.createOrGetBag(String instanceId,
String bagName)
Creates a bag or gets an existing one if it already existed for the specified instance.
|
DBSession |
DBSessionFactory.createSession()
Creates a DB Session
|
DBSession |
DBSessionFactory.createSession(Credentials credentials)
Creates a DB Session with given credentials
|
DBSession |
DBSessionFactory.createSession(String instance)
Creates a session for the given instance
|
DBSession |
DBSessionFactory.createSession(String instance,
Credentials credentials)
Creates a session for the given instance and credentials
|
Instance |
DBConnectorSession.deleteInstance(String instanceId) |
Instance |
DBSession.deleteInstance(String instanceId)
This deletes an instance all its related bags and entities permanently.
|
void |
RemoteUserAdministration.deleteUser(String username) |
void |
UserAdministration.deleteUser(String username)
Deletes a user from the database, does not revoke grants
|
void |
RemoteEntityBag.ensureIndex(CompositeIndexField queryFields,
boolean isUnique,
IndexField... valueFields) |
void |
RemoteEntityBag.ensureIndex(IndexField indexField,
boolean isUnique,
IndexField... valueFields) |
QueryResult |
RemoteQueryExecutor.execute() |
QueryExecutor |
RemoteEntityBag.find(CompositeQueryField queryFields,
SortParameter... params) |
QueryExecutor |
RemoteEntityBag.find(QueryBuilder queryBuilder) |
QueryExecutor |
RemoteEntityBag.find(QueryField queryField,
SortParameter... params) |
void |
RemoteEntityBag.flush() |
EntityBag |
DBConnectorSession.getBag(String bagName) |
EntityBag |
DBSession.getBag(String bagName)
Retrieves an existing bag if this exists on the connected instance, in case the bag does not
exist the method will return null
|
EntityBag |
DBConnectorSession.getBag(String instanceId,
String bagName) |
EntityBag |
DBSession.getBag(String instanceId,
String bagName)
Retrieves an existing bag if this exists on the specified instance, in case the bag does not
exist the method will return null
|
List<EntityBag> |
DBConnectorSession.getBags() |
List<EntityBag> |
DBSession.getBags()
Gets a list of all existing bags in the default database instance
|
List<EntityBag> |
DBConnectorSession.getBags(String instanceId) |
List<EntityBag> |
DBSession.getBags(String instanceId)
Gets a list of all existing bags in the specified database instance
|
long |
RemoteEntityBag.getDiskSize() |
QueryResult |
RemoteEntityBag.getEntities() |
QueryResult |
RemoteEntityBag.getEntities(int max) |
SimpleEntity |
RemoteEntityBag.getEntity(String entityId) |
List<String> |
RemoteEntityBag.getIndexNames() |
Instance |
DBConnectorSession.getInstance(String instanceId) |
Instance |
DBSession.getInstance(String instanceId)
Gets the metadata of a specific instance
|
String |
DBConnectorSession.getInstanceId() |
String |
DBSession.getInstanceId()
Gets the instance id of the currently connected instance
|
List<Instance> |
DBConnectorSession.getInstances() |
List<Instance> |
DBSession.getInstances()
Gets a list of all available instances
|
String |
RemoteEntityBag.getName() |
long |
RemoteEntityBag.getSize() |
UserAdministration |
DBConnectorSession.getUserAdministration() |
UserAdministration |
DBSession.getUserAdministration() |
List<String> |
RemoteUserAdministration.getUsers() |
List<String> |
UserAdministration.getUsers()
Gets a list of all the users
|
void |
RemoteUserAdministration.grant(String username,
String object,
AccessMode mode) |
void |
UserAdministration.grant(String username,
String object,
AccessMode mode)
GrantObject the user access to the specified object with the given access level
|
void |
DBConnectorSession.removeBag(String bagName) |
void |
DBSession.removeBag(String bagName)
Removes a bag from the current instance if it exists and is not in use
|
void |
DBConnectorSession.removeBag(String instanceId,
String bagName) |
void |
DBSession.removeBag(String instanceId,
String bagName)
Removes a bag from the specified instance if it exists and is not in use
|
void |
RemoteEntityBag.removeEntity(SimpleEntity entity) |
void |
RemoteEntityBag.removeEntity(String entityId) |
void |
RemoteEntityBag.removeIndex(String indexKeyName) |
void |
RemoteUserAdministration.revoke(String username,
String object) |
void |
UserAdministration.revoke(String username,
String object)
Revokes a grant for a given user
|
void |
DBConnectorSession.switchInstance(String instanceId) |
void |
DBSession.switchInstance(String instanceId)
Switches the current session to a new instance
|
SimpleEntity |
RemoteEntityBag.updateEntity(SimpleEntity entity) |
Constructor and Description |
---|
DBConnectorSession(String instance,
Credentials credentials,
NodeInformation nodeInformation) |
DBConnectorSession(String instance,
NodeInformation nodeInformation) |
Modifier and Type | Method and Description |
---|---|
User |
CredentialsProvider.addUser(String userName,
String allowedHost,
String contentKey,
String password) |
User |
UserManager.addUser(UserSession currentSession,
String userName,
String allowedHost,
String password) |
User |
UserManager.authenticate(Credentials credentials) |
void |
UserManager.authorize(UserSession userSession,
String object,
AccessMode mode) |
void |
CredentialsProvider.deleteUser(String userName) |
void |
UserManager.deleteUser(UserSession currentSession,
String userName) |
void |
SessionManager.endSession(String sessionId) |
List<UserSession> |
SessionManager.getActiveSessions() |
GrantObject |
UserManager.getGrantObject(UserSession session,
String object) |
List<GrantObject> |
UserManager.getGrantObjects(UserSession session) |
UserSession |
SessionManager.getSession(String sessionId) |
User |
CredentialsProvider.getUser(String userName,
String sourceHost,
String password) |
List<String> |
CredentialsProvider.getUsers() |
List<String> |
UserManager.getUsers(UserSession currentSession) |
void |
UserManager.grantUser(UserSession currentSession,
String object,
String userName,
AccessMode mode) |
void |
UserManager.revoke(UserSession currentSession,
String object,
String userName) |
boolean |
SessionManager.sessionValid(String sessionId) |
UserSession |
SessionManager.startSession(Credentials credentials) |
Modifier and Type | Method and Description |
---|---|
void |
MetadataStore.addBag(Bag bag)
Adds a new bag to the storage
|
void |
MetadataStore.addBagIndex(String instanceId,
String bagName,
IndexDefinition indexDefinition)
Adds an index to an existing bag in a certain instance
|
void |
MetadataStore.addInstance(Instance instance)
Adds an instance using the specified instance metadata
|
long |
MetadataStore.addMetadataEntity(SimpleEntity entity)
Generic operation to add a metadata entity to the metadata store
|
void |
MetadataStore.closeStore()
Close the store
|
boolean |
MetadataStore.containsBag(String instanceId,
String bag)
Checks if a bag in an instance exists in the metadata store
|
boolean |
MetadataStore.containsIndex(String instanceId,
String bagName,
IndexDefinition indexDefinition)
Checks if the index is already present in the metadata store
|
boolean |
MetadataStore.containsInstance(String instanceId)
Checks if the instance alredy exists
|
void |
MetadataStore.deleteMetadataEntity(long recordPointer)
Deletes a generic metadata entity
|
Bag |
MetadataStore.getBag(String instanceId,
String bag)
Gets the a specific bag in an instance
|
List<Bag> |
MetadataStore.getBags(String instanceId)
Gets the bags for the given instanceId
|
Instance |
MetadataStore.getInstance(String instanceId)
Gets a specific instance identified by the instanceId
|
List<Instance> |
MetadataStore.getInstances()
Gets the registered instances
|
boolean |
MetadataStore.isLastShutdownClean()
Checks whether the last shutdown was done cleanly
|
void |
MetadataProvider.registerMetadataEntity(SimpleEntity entity,
long recordPointer) |
void |
MetadataStore.removeBag(String instanceId,
String name)
Remove a bag from the metadata store
|
void |
MetadataStore.removeBagIndex(String instanceId,
String bagName,
IndexDefinition indexDefinition) |
void |
MetadataStore.removeInstance(String instanceId)
Removes an instance from the metadata list
|
void |
MetadataStore.updateInstance(Instance instance)
Updates the instance metadata
|
long |
MetadataStore.updateMetadataEntity(SimpleEntity entity,
long previousRecord)
Generic operation to update a metadata entity in the metadata store
|
Modifier and Type | Method and Description |
---|---|
SimpleEntity |
EntityBag.addEntity(SimpleEntity entity)
Adds an entity to the bag of entities
|
void |
DBInstanceFactory.addInstance(String instanceId,
String path)
Adds a new instance with default configuration with a specified
database path
|
Index |
IndexManager.createIndex(String bagName,
CompositeIndexField compositeIndexFields,
boolean unique,
IndexField... values) |
Index |
IndexManager.createIndex(String bagName,
IndexField indexField,
boolean unique,
IndexField... valueFields) |
void |
DBInstanceFactory.deleteInstance(String instanceId)
Deletes an instance and all of its resources, this operation is destructive and
will remove all data permanently.
|
void |
EntityBag.ensureIndex(CompositeIndexField indexField,
boolean isUnique,
IndexField... valueFields)
Ensures there is an index present on a given amount of fields in this bag, will create if not existent, will do nothing
if index already exists.
|
void |
EntityBag.ensureIndex(IndexField indexField,
boolean isUnique,
IndexField... valueFields)
Ensures there is an index present on a given field in this bag, will create if not existent, will do nothing
if index already exists.
|
QueryExecutor |
EntityBag.find(CompositeQueryField queryFields,
SortParameter... params)
Builds a query for document in the storage for multiple queryfields with optional sorting parameters
|
QueryExecutor |
EntityBag.find(QueryBuilder queryBuilder)
Builds a query for document in the storage using the QueryBuilder which has a fluent query building mechanism.
|
QueryExecutor |
EntityBag.find(QueryField queryField,
SortParameter... params)
Builds a query for document in the storage for a specific queryfield with optional sorting parameters
|
void |
IndexManager.flush() |
void |
EntityBag.flush()
Forcibly flushes all the data in the bag to the storage
|
void |
IndexManager.flush(String bagName) |
Bag |
DBInstance.getBag(String bagName)
Retrieves the bag metadata for a bag with given name in this instance
|
List<Bag> |
DBInstance.getBags()
Retrieves the list of bags for this instance
|
Index |
IndexManager.getBestMatchingIndex(String bagName,
Set<String> fields) |
long |
EntityBag.getDiskSize()
Returns the size on the disk of the entities
|
QueryResult |
EntityBag.getEntities()
Execute a query returning all records in the bag
|
QueryResult |
EntityBag.getEntities(int max)
Execute a query returning all records in the bag with a given max
|
SimpleEntity |
EntityBag.getEntity(String entityId)
Retrieves a specific entity from the bag
|
Index |
IndexManager.getIndex(String bagName,
String keyName) |
Map<String,Index> |
IndexManager.getIndexes(String bagName) |
IndexManager |
IndexManagerFactory.getIndexManager(String instanceId) |
List<String> |
EntityBag.getIndexNames()
Gets a list of all the index names on this bag
|
String |
EntityBag.getName()
Returns the name of the bag containing all data
|
long |
EntityBag.getSize()
Returns the amount of entities in the bag
|
void |
DBInstance.removeBag(String bagName)
Removes the requested bag from this instance, will remove the bag with all data and its
indexes
|
void |
EntityBag.removeEntity(SimpleEntity entity)
Remove the entity from the bag
|
void |
EntityBag.removeEntity(String entityId)
Removes the entity from the bag using the id
|
void |
EntityBag.removeIndex(String indexKeyName)
Removes the index from the bag
|
void |
IndexManager.removeIndex(String bagName,
String keyName) |
void |
IndexManagerFactory.shutdownIndexes() |
void |
IndexManager.shutdownIndexes() |
SimpleEntity |
EntityBag.updateEntity(SimpleEntity entity)
Updates an entity in the bag of entities
|
Modifier and Type | Method and Description |
---|---|
QueryResult |
QueryExecutor.execute() |
Modifier and Type | Method and Description |
---|---|
void |
DBInstanceFactoryImpl.addInstance(String instanceId,
String path) |
void |
DBInstanceFactoryImpl.deleteInstance(String instanceId) |
Bag |
DBInstanceImpl.getBag(String bagName) |
List<Bag> |
DBInstanceImpl.getBags() |
static DBInstanceFactory |
SimpleKernel.getInstanceFactory() |
static <T> T |
SimpleKernel.getKernelModule(Class<T> requiredModuleType) |
static NodeInformation |
SimpleKernel.getNodeInformation() |
static StorageServiceFactory |
SimpleKernel.getStorageServiceFactory() |
void |
DBInstanceFactoryImpl.initializeServices() |
void |
DBInstanceImpl.removeBag(String bagName) |
Constructor and Description |
---|
DBInstanceFactoryImpl(MetadataStore metadataStore) |
Modifier and Type | Method and Description |
---|---|
void |
CacheEntry.release() |
Modifier and Type | Method and Description |
---|---|
static CryptoEngine |
CryptoFactory.getEngine(String engineDescriptor) |
Modifier and Type | Method and Description |
---|---|
User |
DummyCredentialsProvider.addUser(String userName,
String allowedHost,
String contentKey,
String password) |
User |
DummyUserManager.addUser(UserSession currentSession,
String userName,
String allowedHost,
String password) |
User |
DummyUserManager.authenticate(Credentials credentials) |
void |
DummyUserManager.authorize(UserSession userSession,
String object,
AccessMode mode) |
void |
DummyCredentialsProvider.deleteUser(String userName) |
void |
DummyUserManager.deleteUser(UserSession currentSession,
String userName) |
void |
DummySessionManager.endSession(String sessionId) |
List<UserSession> |
DummySessionManager.getActiveSessions() |
GrantObject |
DummyUserManager.getGrantObject(UserSession session,
String object) |
List<GrantObject> |
DummyUserManager.getGrantObjects(UserSession session) |
UserSession |
DummySessionManager.getSession(String sessionId) |
User |
DummyCredentialsProvider.getUser(String userName,
String sourceHost,
String password) |
List<String> |
DummyCredentialsProvider.getUsers() |
List<String> |
DummyUserManager.getUsers(UserSession currentSession) |
void |
DummyUserManager.grantUser(UserSession currentSession,
String object,
String userName,
AccessMode mode) |
void |
DummyUserManager.revoke(UserSession currentSession,
String object,
String userName) |
boolean |
DummySessionManager.sessionValid(String sessionId) |
UserSession |
DummySessionManager.startSession(Credentials credentials) |
Modifier and Type | Class and Description |
---|---|
class |
ConfigurationException
This exception is thrown when an issue is found in the provided
configuration file
|
class |
DatastoreException |
class |
JasDBSecurityException |
class |
LocatorException
User: renarj
Date: 1/16/12
Time: 9:52 PM
|
class |
MetadataParseException
User: Renze de Vries
Date: 1/8/12
Time: 2:20 PM
|
class |
NoComponentFoundException |
Modifier and Type | Method and Description |
---|---|
static File |
HomeLocatorUtil.determineDatastoreLocation() |
Modifier and Type | Method and Description |
---|---|
void |
RecordWriter.closeWriter()
This closes the writer channel and releases all the resources
|
RecordWriter |
RecordWriterFactory.createWriter(File file)
Creates a record writer for the given file location
|
void |
RecordWriter.flush()
Guarantees the changes are flushed to the disk
|
long |
RecordWriter.getDiskSize()
Gets the disk size of the persistence storage
|
long |
RecordWriter.getSize()
Gets the amount of data streams / records stored
|
ClonableDataStream |
RecordResult.getStream()
Gets an inputstream allowing reading of the record entity
|
void |
RecordWriter.openWriter()
This opens the writer for all access, needs to be done before any operations are done on the recordwriter
|
RecordIterator |
RecordWriter.readAllRecords()
This returns an iterator that can iterate over all persisted records.
|
RecordIterator |
RecordWriter.readAllRecords(int limit)
This returns an iterator that can iterate over all persisted records to a defined limit.
|
RecordResult |
RecordWriter.readRecord(UUIDKey documentId)
This reads a specific record at the indicated record position
|
void |
RecordWriter.removeRecord(UUIDKey documentId)
This will command the writer to remove the indicated record from storage.
|
void |
RecordWriter.updateRecord(UUIDKey documentId,
ClonableDataStream dataStream)
This updates the record contents stored in storage for a given updated content and the current
record pointer to the record.
|
void |
RecordWriter.writeRecord(UUIDKey documentId,
ClonableDataStream dataStream)
This writes the given content to the filesystem and returns the record pointer at which the record
can be retrieved on next attempt.
|
Modifier and Type | Method and Description |
---|---|
void |
DataBlockFactory.close() |
void |
Block.close() |
void |
DataBlockFactory.flush() |
void |
DataBlock.flush() |
DataBlock |
DataBlockFactory.getBlockWithSpace(boolean allowFragmented) |
DataBlock |
DataBlockFactory.getHeaderBlock() |
int |
DataBlockHeader.getInt(int offset) |
long |
DataBlockHeader.getLong(int offset) |
DataBlock |
DataBlockFactory.loadBlock(long position) |
DataBlock |
DataBlockFactory.loadBlockForDataPosition(long dataPosition) |
DataBlockResult<byte[]> |
DataBlock.loadBytes(int offset)
Load bytes from the datablock, providing an offset from the start of the block.
|
DataBlockResult<byte[]> |
DataBlock.loadBytes(long absolutePosition) |
DataBlockResult<Long> |
DataBlock.loadLong(int offset) |
DataBlockResult<Long> |
DataBlock.loadLong(long absolutePosition) |
DataBlock |
DataBlock.loadNext() |
DataBlockResult<BlockDataInputStream> |
DataBlock.loadStream(int offset) |
DataBlockResult<BlockDataInputStream> |
DataBlock.loadStream(long absolutePosition) |
void |
DataBlockFactory.open() |
void |
DataBlockHeader.putInt(int offset,
int value) |
void |
DataBlockHeader.putLong(int offset,
long value) |
void |
DataBlockFactory.releaseBlock(long position) |
DataBlock.WriteResult |
DataBlock.writeBytes(byte[] bytes) |
DataBlock.WriteResult |
DataBlock.writeLong(long value) |
DataBlock.WriteResult |
DataBlock.writeStream(InputStream stream) |
Modifier and Type | Method and Description |
---|---|
void |
DataBlockImpl.close() |
void |
DataBlockFactoryImpl.close() |
void |
DataBlockImpl.flush() |
void |
DataBlockFactoryImpl.flush() |
DataBlock |
DataBlockFactoryImpl.getBlockWithSpace(boolean allowFragmented) |
DataBlock |
DataBlockFactoryImpl.getHeaderBlock() |
int |
DataBlockHeaderImpl.getInt(int offset) |
long |
DataBlockHeaderImpl.getLong(int offset) |
DataBlock |
DataBlockFactoryImpl.loadBlock(long position) |
DataBlock |
DataBlockFactoryImpl.loadBlockForDataPosition(long dataPosition) |
DataBlockResult<byte[]> |
DataBlockImpl.loadBytes(int offset) |
DataBlockResult<byte[]> |
DataBlockImpl.loadBytes(long absolutePosition) |
DataBlockResult<Long> |
DataBlockImpl.loadLong(int offset) |
DataBlockResult<Long> |
DataBlockImpl.loadLong(long absolutePosition) |
DataBlock |
DataBlockImpl.loadNext() |
DataBlockResult<BlockDataInputStream> |
DataBlockImpl.loadStream(int offset) |
DataBlockResult<BlockDataInputStream> |
DataBlockImpl.loadStream(long absolutePosition) |
void |
DataBlockFactoryImpl.open() |
void |
DataBlockHeaderImpl.putInt(int offset,
int value) |
void |
DataBlockHeaderImpl.putLong(int offset,
long value) |
void |
BlockEntry.release() |
void |
DataBlockFactoryImpl.releaseBlock(long position) |
DataBlock.WriteResult |
DataBlockImpl.writeBytes(byte[] bytes) |
DataBlock.WriteResult |
DataBlockImpl.writeDataStream(InputStream stream,
boolean isDelegate) |
DataBlock.WriteResult |
DataBlockImpl.writeLong(long value) |
DataBlock.WriteResult |
DataBlockImpl.writeStream(InputStream stream) |
Modifier and Type | Method and Description |
---|---|
static void |
IndexRebuildUtil.bulkInsertIndex(Index index,
KeyInfo keyInfo,
Iterator<IndexableItem> indexableItems) |
void |
Index.close()
Close the index and all its used resources
|
static IndexScanReport |
IndexScanner.doIndexScan(Index index,
KeyInfo keyInfo,
Iterator<IndexableItem> indexableItems,
boolean fullScan) |
void |
Index.flushIndex()
This persists the changes to the disk backing of the index
|
IndexIterator |
Index.getIndexIterator()
This gets an iterator which allows iterating over the full index collection
|
MemoryAware |
Index.getMemoryManager()
This is the memory manager of the index, this is used to determine vital memory parameters.
|
void |
Index.insertIntoIndex(Key key)
Inserts the given key into the index, the key is to expected to conform to the index key specification as determined
in the keyinfo.
|
void |
Index.openIndex()
Opens the index and its resources
|
void |
Index.rebuildIndex(Iterator<IndexableItem> indexableItems)
Do a full rebuild of the index and fully populate it based on provided item iterator
|
void |
Index.removeFromIndex(Key key)
Remove the given key and its values from the index.
|
void |
Index.removeIndex()
Removes the index and all used resources
|
IndexScanReport |
Index.scan(ScanIntent intent,
Iterator<IndexableItem> scanItems)
This performs a scan of the index and reports on the integrity.
|
IndexSearchResultIteratorCollection |
Index.searchIndex(SearchCondition searchCondition,
SearchLimit searchLimit)
Do a search operation of the index given the searchcondition.
|
void |
Index.updateKey(Key oldKey,
Key newKey)
Update the key payload inside the index, the key is to expected to conform to the index key specification as determined
in the keyinfo.
|
Modifier and Type | Method and Description |
---|---|
protected void |
TreeBlock.addNodes(List<TreeNode> nodes,
Key exclude,
long parentBlock) |
void |
TreeBlock.close() |
void |
LeaveBlockImpl.close() |
void |
BTreeIndex.close() |
void |
BlockPersister.close() |
IndexBlock |
BlockPersister.createBlock(BlockTypes blockType,
long parentBlock) |
static IndexHeader |
BtreeIndexHeader.createHeader(DataBlock headerBlock,
int pageSize,
long count,
KeyInfo keyInfo) |
LeaveBlock |
TreeBlock.findFirstLeaveBlock(LockIntentType intentType) |
LeaveBlock |
RootBlock.findFirstLeaveBlock(LockIntentType intentType) |
LeaveBlock |
LeaveBlockImpl.findFirstLeaveBlock(LockIntentType intentType) |
LeaveBlock |
IndexBlock.findFirstLeaveBlock(LockIntentType intent) |
LeaveBlock |
TreeBlock.findLeaveBlock(LockIntentType intent,
Key key) |
LeaveBlock |
RootBlock.findLeaveBlock(LockIntentType intent,
Key key) |
LeaveBlockImpl |
LeaveBlockImpl.findLeaveBlock(LockIntentType intent,
Key key) |
LeaveBlock |
IndexBlock.findLeaveBlock(LockIntentType intent,
Key key) |
void |
BlockPersister.flush() |
void |
BTreeIndex.flushIndex() |
IndexIterator |
BTreeIndex.getIndexIterator() |
protected LockManager |
BTreeIndex.getLockManager() |
protected Key |
TreeBlock.getMax() |
MemoryAware |
BTreeIndex.getMemoryManager() |
protected Key |
TreeBlock.getMin() |
protected BlockPersister |
BTreeIndex.getPersister() |
protected RootBlock |
BTreeIndex.getRootBlock() |
protected void |
TreeBlock.handleBlockUnderflow() |
protected void |
TreeBlock.insertBlock(Key key,
IndexBlock leftChildBlock,
IndexBlock rightChildBlock) |
void |
BTreeIndex.insertIntoIndex(Key key) |
void |
RootBlock.insertKey(Key key) |
void |
LeaveBlockImpl.insertKey(Key key) |
void |
LeaveBlock.insertKey(Key key) |
static IndexHeader |
BtreeIndexHeader.loadAndValidateHeader(DataBlock dataBlock,
KeyInfo keyInfo) |
IndexBlock |
BlockPersister.loadBlock(long position) |
void |
BlockPersister.markDeleted(IndexBlock block) |
void |
BTreeIndex.openIndex() |
void |
BlockPersister.persistBlock(IndexBlock block) |
void |
BTreeIndex.rebuildIndex(Iterator<IndexableItem> indexableItems) |
protected void |
TreeBlock.removeBlockPointer(Key minBlockValue,
IndexBlock removedBlock) |
protected void |
RootBlock.removeBlockPointer(Key minBlockValue,
IndexBlock removedBlock) |
void |
BTreeIndex.removeFromIndex(Key key) |
void |
BTreeIndex.removeIndex() |
void |
RootBlock.removeKey(Key key) |
void |
LeaveBlockImpl.removeKey(Key key) |
void |
LeaveBlock.removeKey(Key key) |
protected void |
LeaveBlockImpl.removeKeyInternal(Key key) |
void |
BTreeIndex.resetIndex() |
IndexScanReport |
BTreeIndex.scan(ScanIntent intent,
Iterator<IndexableItem> indexableItems) |
IndexSearchResultIteratorCollection |
BTreeIndex.searchIndex(SearchCondition searchCondition,
SearchLimit searchLimit) |
protected void |
TreeBlock.updateBlockPointer(Key replaceKey,
long leftBlock,
long rightBlock) |
void |
RootBlock.updateKey(Key key) |
void |
LeaveBlockImpl.updateKey(Key key) |
void |
LeaveBlock.updateKey(Key key) |
void |
BTreeIndex.updateKey(Key oldKey,
Key newKey) |
Modifier and Type | Method and Description |
---|---|
abstract void |
AbstractMemoryBlock.close() |
void |
IndexBlockEntry.release() |
Modifier and Type | Method and Description |
---|---|
void |
BtreePlusBlockPersister.close() |
IndexBlock |
BtreePlusBlockPersister.createBlock(BlockTypes blockType,
long parentBlock) |
RootBlock |
RootBlockFactory.createBlock(long parentBlock,
DataBlock dataBlock) |
TreeBlock |
NodeBlockFactory.createBlock(long parentBlock,
DataBlock dataBlock) |
LeaveBlockImpl |
LeaveBlockFactory.createBlock(long parentBlock,
DataBlock dataBlock) |
T |
BlockFactory.createBlock(long parentBlock,
DataBlock dataBlock) |
void |
BtreePlusBlockPersister.flush() |
void |
BtreePlusBlockPersister.flushAndCloseBlock(IndexBlock block) |
RootBlock |
RootBlockFactory.loadBlock(DataBlock dataBlock) |
TreeBlock |
NodeBlockFactory.loadBlock(DataBlock dataBlock) |
LeaveBlock |
LeaveBlockFactory.loadBlock(DataBlock dataBlock) |
T |
BlockFactory.loadBlock(DataBlock dataBlock) |
IndexBlock |
BtreePlusBlockPersister.loadBlock(long position) |
protected KeyLoadResult |
RootBlockFactory.loadKeyResult(TreeBlock treeBlock,
int offset,
DataBlock dataBlock) |
protected KeyLoadResult |
NodeBlockFactory.loadKeyResult(TreeBlock treeBlock,
int offset,
DataBlock dataBlock) |
void |
BtreePlusBlockPersister.markDeleted(IndexBlock block) |
void |
BtreePlusBlockPersister.persistBlock(IndexBlock block) |
void |
LeaveBlockFactory.persistBlock(LeaveBlock block) |
void |
BlockFactory.persistBlock(T block) |
void |
RootBlockFactory.persistBlock(TreeBlock treeBlock) |
void |
NodeBlockFactory.persistBlock(TreeBlock treeBlock) |
static void |
RootBlockFactory.writeHeader(DataBlock block,
boolean isLeave) |
protected DataBlock |
RootBlockFactory.writeKey(TreeBlock treeBlock,
Key key,
DataBlock dataBlock) |
protected DataBlock |
NodeBlockFactory.writeKey(TreeBlock treeBlock,
Key key,
DataBlock dataBlock) |
Modifier and Type | Method and Description |
---|---|
IndexSearchResultIteratorCollection |
SearchOperation.search(SearchCondition condition,
SearchLimit limit) |
IndexSearchResultIteratorCollection |
RangeSearchOperation.search(SearchCondition condition,
SearchLimit limit) |
IndexSearchResultIteratorCollection |
NotEqualsSearchOperation.search(SearchCondition condition,
SearchLimit limit) |
IndexSearchResultIteratorCollection |
EqualsSearchOperation.search(SearchCondition condition,
SearchLimit limit) |
protected static EqualsCondition |
EqualsSearchOperation.validateCondition(KeyInfo keyInfo,
SearchCondition condition) |
Modifier and Type | Method and Description |
---|---|
static UUIDKey |
KeyUtil.getDocumentKey(KeyNameMapper keyNameMapper,
Key key) |
Modifier and Type | Method and Description |
---|---|
Key |
WrappedValueKeyFactory.convertKey(Key key) |
Key |
UUIDKeyFactory.convertKey(Key key) |
Key |
StringKeyFactory.convertKey(Key key) |
Key |
LongKeyFactory.convertKey(Key key) |
Key |
KeyFactory.convertKey(Key key) |
Key |
DataKeyFactory.convertKey(Key key) |
Key |
CompositeKeyFactory.convertKey(Key key) |
protected Key |
UUIDKeyFactory.convertToKey(Object value) |
protected Key |
StringKeyFactory.convertToKey(Object value) |
protected Key |
LongKeyFactory.convertToKey(Object value) |
protected Key |
DataKeyFactory.convertToKey(Object value) |
protected abstract Key |
AbstractKeyFactory.convertToKey(Object value) |
Key |
WrappedValueKeyFactory.createKey(IndexableItem indexableItem) |
Key |
UUIDKeyFactory.createKey(IndexableItem indexableItem) |
Key |
StringKeyFactory.createKey(IndexableItem indexableItem) |
Key |
LongKeyFactory.createKey(IndexableItem indexableItem) |
Key |
KeyFactory.createKey(IndexableItem indexableItem) |
Key |
DataKeyFactory.createKey(IndexableItem indexableItem) |
Key |
CompositeKeyFactory.createKey(IndexableItem indexableItem) |
static KeyFactory |
KeyFactoryManager.createKeyFactory(String field,
KeyType keyType) |
Set<Key> |
WrappedValueKeyFactory.createMultivalueKeys(IndexableItem indexableItem) |
Set<Key> |
KeyFactory.createMultivalueKeys(IndexableItem indexableItem) |
Set<Key> |
CompositeKeyFactory.createMultivalueKeys(IndexableItem indexableItem) |
Set<Key> |
AbstractKeyFactory.createMultivalueKeys(IndexableItem indexableItem) |
boolean |
WrappedValueKeyFactory.isMultiValueKey(IndexableItem indexableItem) |
boolean |
KeyFactory.isMultiValueKey(IndexableItem indexableItem) |
boolean |
CompositeKeyFactory.isMultiValueKey(IndexableItem indexableItem) |
boolean |
AbstractKeyFactory.isMultiValueKey(IndexableItem indexableItem) |
Key |
WrappedValueKeyFactory.loadKey(int curPosition,
ByteBuffer byteBuffer) |
Key |
UUIDKeyFactory.loadKey(int curPosition,
ByteBuffer byteBuffer) |
Key |
StringKeyFactory.loadKey(int curPosition,
ByteBuffer byteBuffer) |
Key |
LongKeyFactory.loadKey(int curPosition,
ByteBuffer byteBuffer) |
Key |
KeyFactory.loadKey(int curPosition,
ByteBuffer byteBuffer) |
Key |
DataKeyFactory.loadKey(int curPosition,
ByteBuffer byteBuffer) |
Key |
CompositeKeyFactory.loadKey(int curPosition,
ByteBuffer byteBuffer) |
KeyLoadResult |
WrappedValueKeyFactory.loadKey(int offset,
DataBlock dataBlock) |
KeyLoadResult |
UUIDKeyFactory.loadKey(int offset,
DataBlock dataBlock) |
KeyLoadResult |
StringKeyFactory.loadKey(int offset,
DataBlock dataBlock) |
KeyLoadResult |
LongKeyFactory.loadKey(int offset,
DataBlock dataBlock) |
KeyLoadResult |
KeyFactory.loadKey(int offset,
DataBlock dataBlock) |
KeyLoadResult |
DataKeyFactory.loadKey(int offset,
DataBlock dataBlock) |
KeyLoadResult |
CompositeKeyFactory.loadKey(int offset,
DataBlock dataBlock) |
static KeyFactory[] |
KeyFactoryManager.parseHeader(String headerDescriptor) |
DataBlock |
WrappedValueKeyFactory.writeKey(Key key,
DataBlock dataBlock) |
DataBlock |
UUIDKeyFactory.writeKey(Key key,
DataBlock dataBlock) |
DataBlock |
StringKeyFactory.writeKey(Key key,
DataBlock dataBlock) |
DataBlock |
LongKeyFactory.writeKey(Key key,
DataBlock dataBlock) |
DataBlock |
KeyFactory.writeKey(Key key,
DataBlock dataBlock) |
DataBlock |
DataKeyFactory.writeKey(Key key,
DataBlock dataBlock) |
DataBlock |
CompositeKeyFactory.writeKey(Key key,
DataBlock dataBlock) |
void |
WrappedValueKeyFactory.writeKey(Key key,
int curPosition,
ByteBuffer byteBuffer) |
void |
UUIDKeyFactory.writeKey(Key key,
int curPosition,
ByteBuffer byteBuffer) |
void |
StringKeyFactory.writeKey(Key key,
int curPosition,
ByteBuffer byteBuffer) |
void |
LongKeyFactory.writeKey(Key key,
int curPosition,
ByteBuffer byteBuffer) |
void |
KeyFactory.writeKey(Key key,
int curPosition,
ByteBuffer byteBuffer) |
void |
DataKeyFactory.writeKey(Key key,
int curPosition,
ByteBuffer byteBuffer) |
void |
CompositeKeyFactory.writeKey(Key key,
int curPosition,
ByteBuffer byteBuffer) |
Modifier and Type | Method and Description |
---|---|
ClonableDataStream |
DataKey.getStream() |
Modifier and Type | Method and Description |
---|---|
void |
MultiKeyLoaderImpl.enrichKey(IndexableItem indexableItem,
Key key) |
void |
MultiKeyloader.enrichKey(IndexableItem indexableItem,
Key key) |
Key |
KeyInfoImpl.loadKey(int curPosition,
ByteBuffer byteBuffer) |
Key |
KeyInfo.loadKey(int curPosition,
ByteBuffer byteBuffer) |
KeyLoadResult |
KeyInfoImpl.loadKey(int curPosition,
DataBlock dataBlock) |
KeyLoadResult |
KeyInfo.loadKey(int curPosition,
DataBlock dataBlock) |
void |
MultiKeyLoaderImpl.loadKeys(Key targetKey,
int offset,
ByteBuffer keyBuffer) |
void |
MultiKeyloader.loadKeys(Key targetKey,
int offset,
ByteBuffer keyBuffer) |
KeyLoadResult |
MultiKeyLoaderImpl.loadKeys(Key targetKey,
int offset,
DataBlock dataBlock) |
KeyLoadResult |
MultiKeyloader.loadKeys(Key targetKey,
int offset,
DataBlock dataBlock) |
DataBlock |
KeyInfoImpl.writeKey(Key key,
DataBlock dataBlock) |
DataBlock |
KeyInfo.writeKey(Key key,
DataBlock dataBlock) |
void |
KeyInfoImpl.writeKey(Key key,
int curPosition,
ByteBuffer byteBuffer) |
void |
KeyInfo.writeKey(Key key,
int curPosition,
ByteBuffer byteBuffer) |
DataBlock |
MultiKeyLoaderImpl.writeKeys(Key sourceKey,
DataBlock dataBlock) |
DataBlock |
MultiKeyloader.writeKeys(Key sourceKey,
DataBlock dataBlock) |
void |
MultiKeyLoaderImpl.writeKeys(Key sourceKey,
int offset,
ByteBuffer keyBuffer) |
void |
MultiKeyloader.writeKeys(Key sourceKey,
int offset,
ByteBuffer keyBuffer) |
Constructor and Description |
---|
KeyInfoImpl(IndexField indexField,
IndexField... valueFields) |
KeyInfoImpl(IndexField indexField,
List<IndexField> valueIndexFields) |
KeyInfoImpl(List<IndexField> keyFields,
List<IndexField> valueFields) |
KeyInfoImpl(String headerDescriptor,
String valueDescriptor) |
Modifier and Type | Class and Description |
---|---|
class |
RemoteException
User: renarj
Date: 1/22/12
Time: 3:26 PM
|
Modifier and Type | Class and Description |
---|---|
class |
ResourceNotFoundException |
Modifier and Type | Method and Description |
---|---|
protected void |
RestDBSession.authenticate(Credentials credentials) |
DBSession |
RestDBSessionFactory.createSession() |
DBSession |
RestDBSessionFactory.createSession(Credentials credentials) |
DBSession |
RestDBSessionFactory.createSession(String instance) |
DBSession |
RestDBSessionFactory.createSession(String instance,
Credentials credentials) |
void |
RestDBSessionFactory.shutdown() |
Constructor and Description |
---|
RestDBSession(String instance,
String hostname,
Credentials credentials,
int sslPort) |
RestDBSession(String instance,
String hostname,
Credentials credentials,
int sslPort,
boolean verifyCertificate) |
RestDBSession(String instance,
String hostname,
int port) |
Modifier and Type | Method and Description |
---|---|
void |
DBSessionTest.addInstance() |
void |
DBSessionTest.addSessionInstanceBound() |
void |
StorageService.closeService()
Closes the service and all its used resources
|
void |
LocalStorageServiceImpl.closeService() |
static Set<Key> |
BagOperationUtil.createEntityKeys(SimpleEntity entity,
Index index) |
protected StorageService |
LocalStorageServiceFactoryImpl.createStorageServiceInstance(Instance instance,
String bagName) |
static void |
BagOperationUtil.doIndexInsert(Set<Key> keys,
Index index) |
void |
StorageService.ensureIndex(CompositeIndexField indexField,
boolean isUnique,
IndexField... valueFields)
Ensures an index with a composite key (multiple fields) is present.
|
void |
LocalStorageServiceImpl.ensureIndex(CompositeIndexField indexField,
boolean isUnique,
IndexField... valueFields) |
void |
StorageService.ensureIndex(IndexField indexField,
boolean isUnique,
IndexField... valueFields)
Ensures an index with the given field is present.
|
void |
LocalStorageServiceImpl.ensureIndex(IndexField indexField,
boolean isUnique,
IndexField... valueFields) |
static Key |
BagOperationUtil.entityToKey(SimpleEntity entity) |
void |
StorageService.flush()
An operation that can be called to guarantee all changes are flushed to the disk.
|
void |
LocalStorageServiceImpl.flush() |
String |
MachineGuidGenerator.generateNewId() |
String |
IdGenerator.generateNewId() |
long |
StorageService.getDiskSize()
Gets the size on the disk (if the flushing strategy is async could misrepresent the real number)
|
long |
LocalStorageServiceImpl.getDiskSize() |
protected List<SimpleEntity> |
QueryBaseTest.getEntities(EntityBag bag,
QueryBuilder query) |
protected List<SimpleEntity> |
QueryBaseTest.getEntities(EntityBag bag,
QueryBuilder query,
int start,
int limit) |
QueryResult |
StorageService.getEntities(RequestContext context)
This retrieves all items from storage with an iterator, the documents are only loaded once the iterator is used.
|
QueryResult |
LocalStorageServiceImpl.getEntities(RequestContext context) |
QueryResult |
StorageService.getEntities(RequestContext context,
int max)
This retrieves all items from storage with an iterator, the documents are only loaded
once the iterator is used.
|
QueryResult |
LocalStorageServiceImpl.getEntities(RequestContext context,
int max) |
SimpleEntity |
StorageService.getEntityById(RequestContext requestContext,
String id)
Retrieve a specific entity from storage by the given unique document id
|
SimpleEntity |
LocalStorageServiceImpl.getEntityById(RequestContext requestContext,
String id) |
List<String> |
StorageService.getIndexNames()
Gets a list of all present index names
|
List<String> |
LocalStorageServiceImpl.getIndexNames() |
StorageService |
StorageServiceFactory.getOrCreateStorageService(String instanceId,
String bagName) |
StorageService |
LocalStorageServiceFactoryImpl.getOrCreateStorageService(String instanceId,
String bagName) |
long |
StorageService.getSize()
Gets the amount of items stored
|
long |
LocalStorageServiceImpl.getSize() |
StorageService |
StorageServiceFactory.getStorageService(String instanceId,
String bagName) |
StorageService |
LocalStorageServiceFactoryImpl.getStorageService(String instanceId,
String bagName) |
void |
StorageService.initializePartitions() |
void |
LocalStorageServiceImpl.initializePartitions() |
void |
LocalStorageServiceFactoryImpl.initializeServices() |
void |
StorageService.insertEntity(RequestContext context,
SimpleEntity entity)
This inserts the entity into the storage and indexes
|
void |
LocalStorageServiceImpl.insertEntity(RequestContext context,
SimpleEntity entity) |
void |
StorageService.openService(Configuration configuration)
Opens the service and all the resources required.
|
void |
LocalStorageServiceImpl.openService(Configuration configuration) |
void |
StorageService.remove()
Removes the bag and all related resources from the storage location
|
void |
LocalStorageServiceImpl.remove() |
void |
StorageServiceFactory.removeAllStorageService(String instanceId) |
void |
LocalStorageServiceFactoryImpl.removeAllStorageService(String instanceId) |
void |
StorageService.removeEntity(RequestContext context,
SimpleEntity entity)
This removes and entity from storage and the indexes
|
void |
LocalStorageServiceImpl.removeEntity(RequestContext context,
SimpleEntity entity) |
void |
StorageService.removeEntity(RequestContext context,
String internalId)
This removes the entity based on the internal id of the entity
|
void |
LocalStorageServiceImpl.removeEntity(RequestContext context,
String internalId) |
void |
StorageService.removeIndex(String indexName)
Removes the index with the given name
|
void |
LocalStorageServiceImpl.removeIndex(String indexName) |
void |
StorageServiceFactory.removeStorageService(String instanceId,
String bagName) |
void |
LocalStorageServiceFactoryImpl.removeStorageService(String instanceId,
String bagName) |
QueryResult |
StorageService.search(RequestContext context,
BlockOperation blockOperation,
SearchLimit limit,
List<SortParameter> params)
This is the query entrypoint, all API queries are translated into a Query Object Model which can be executed on the
indexes and be sorted after all index queries have been resolved
|
QueryResult |
LocalStorageServiceImpl.search(RequestContext context,
BlockOperation blockOperation,
SearchLimit limit,
List<SortParameter> params) |
void |
StorageServiceFactory.shutdownServiceFactory() |
void |
LocalStorageServiceFactoryImpl.shutdownServiceFactory() |
void |
StorageFlushThread.stop() |
void |
DBSessionTest.testBagCreateOrGet() |
void |
EntityBagTest.testBagFlush() |
void |
DBSessionTest.testBagGetNonExisting() |
void |
DBSessionTest.testBagRemove() |
void |
DBSessionTest.testBagRemoveInstance() |
void |
DBSessionTest.testCreateAndGetInstanceBag() |
void |
DBSessionTest.testCreateAndInsertEntities() |
void |
DBSessionTest.testDeleteInstance() |
void |
EntityBagTest.testEnsureAndRemoveIndex() |
void |
EntityManagerTest.testEntityManagerUpdate() |
void |
DBSessionTest.testGetBagList() |
void |
DBSessionTest.testGetInstances() |
void |
DBSessionTest.testGetNonExistingInstance() |
void |
DBSessionTest.testSwitchInstance() |
static SimpleEntity |
BagOperationUtil.toEntity(InputStream stream) |
static ClonableDataStream |
BagOperationUtil.toStream(SimpleEntity entity) |
void |
StorageService.updateEntity(RequestContext context,
SimpleEntity entity)
This updates the entity in the storage and indexes if needed
|
void |
LocalStorageServiceImpl.updateEntity(RequestContext context,
SimpleEntity entity) |
Modifier and Type | Method and Description |
---|---|
void |
JasDBMetadataStore.addBag(Bag bag) |
void |
JasDBMetadataStore.addBagIndex(String instanceId,
String bagName,
IndexDefinition indexDefinition) |
void |
JasDBMetadataStore.addInstance(Instance instance) |
long |
JasDBMetadataStore.addMetadataEntity(SimpleEntity entity) |
void |
JasDBMetadataStore.closeStore() |
boolean |
JasDBMetadataStore.containsBag(String instanceId,
String bag) |
boolean |
JasDBMetadataStore.containsIndex(String instanceId,
String bagName,
IndexDefinition indexDefinition) |
boolean |
JasDBMetadataStore.containsInstance(String instanceId) |
void |
JasDBMetadataStore.deleteMetadataEntity(long recordPointer) |
static BagMeta |
BagMeta.fromEntity(SimpleEntity entity) |
Bag |
JasDBMetadataStore.getBag(String instanceId,
String name) |
List<Bag> |
JasDBMetadataStore.getBags(String instanceId) |
Instance |
JasDBMetadataStore.getInstance(String instanceId) |
List<Instance> |
JasDBMetadataStore.getInstances() |
boolean |
JasDBMetadataStore.isLastShutdownClean() |
void |
JasDBMetadataStore.removeBag(String instanceId,
String name) |
void |
JasDBMetadataStore.removeBagIndex(String instanceId,
String bagName,
IndexDefinition indexDefinition) |
void |
JasDBMetadataStore.removeInstance(String instanceId) |
static SimpleEntity |
BagMeta.toEntity(Bag bag) |
void |
JasDBMetadataStore.updateInstance(Instance instance) |
long |
JasDBMetadataStore.updateMetadataEntity(SimpleEntity entity,
long previousRecord) |
Constructor and Description |
---|
JasDBMetadataStore() |
Modifier and Type | Method and Description |
---|---|
void |
DataOperation.doDataOperation(String instanceId,
String bag,
SimpleEntity entity) |
void |
BagUpdateOperation.doDataOperation(String instanceId,
String bag,
SimpleEntity entity) |
void |
BagRemoveOperation.doDataOperation(String instanceId,
String bag,
SimpleEntity entity) |
void |
BagInsertOperation.doDataOperation(String instanceId,
String bag,
SimpleEntity entity) |
Modifier and Type | Method and Description |
---|---|
boolean |
PartitioningManager.changePartitionStatus(String partitionId,
String targetState) |
boolean |
LocalPartitionManager.changePartitionStatus(String partitionId,
String targetState) |
List<PartitionInformationWrapper> |
PartitioningManager.getKnownPartitions() |
List<PartitionInformationWrapper> |
LocalPartitionManager.getKnownPartitions() |
BagPartition |
PartitioningManager.getLocalPartition(String partitionId) |
BagPartition |
LocalPartitionManager.getLocalPartition(String partitionId) |
void |
PartitioningManager.initializePartitions() |
void |
LocalPartitionManager.initializePartitions() |
List<BagPartition> |
PartitioningManager.splitPartition(BagPartition partition) |
List<BagPartition> |
LocalPartitionManager.splitPartition(BagPartition partition) |
Modifier and Type | Method and Description |
---|---|
IndexSearchResultIteratorCollection |
TableScanOperation.doTableScan(BlockOperation operation,
Set<String> fields,
IndexSearchResultIteratorCollection currentResults) |
IndexSearchResultIteratorCollection |
TableScanOperation.doTableScanFindAll() |
QueryResult |
EntityRetrievalOperation.getEntities() |
QueryResult |
EntityRetrievalOperation.getEntities(int max) |
SimpleEntity |
EntityRetrievalOperation.getEntityById(String entityId) |
protected static Key |
PropertyKeyMapper.mapToKey(Property property) |
protected static Set<Key> |
PropertyKeyMapper.mapToKeys(Property property) |
QueryResult |
QuerySearchOperation.search(BlockOperation blockOperation,
SearchLimit limit,
List<SortParameter> params) |
Modifier and Type | Method and Description |
---|---|
void |
RecordWriterFactoryLoader.closeRecordWriters() |
void |
CachedRecordWriter.closeWriter() |
void |
CachedRecordWriter.flush() |
long |
CachedRecordWriter.getDiskSize() |
long |
CachedRecordWriter.getSize() |
RecordWriter |
RecordWriterFactoryLoader.loadRecordWriter(String instanceId,
String bagName) |
void |
CachedRecordWriter.openWriter() |
RecordIterator |
CachedRecordWriter.readAllRecords() |
RecordIterator |
CachedRecordWriter.readAllRecords(int limit) |
RecordResult |
CachedRecordWriter.readRecord(UUIDKey documentId) |
void |
RecordWriterFactoryLoader.remove(String instanceId,
String bagName) |
void |
CachedRecordWriter.removeRecord(UUIDKey documentId) |
static String |
RecordStreamUtil.toString(InputStream inputStream) |
static String |
RecordStreamUtil.toString(RecordResult result) |
void |
CachedRecordWriter.updateRecord(UUIDKey documentId,
ClonableDataStream dataStream) |
void |
CachedRecordWriter.writeRecord(UUIDKey documentId,
ClonableDataStream dataStream) |
Modifier and Type | Method and Description |
---|---|
void |
BtreeIndexRecordWriter.closeWriter() |
RecordWriter |
BTreeRecordWriterFactory.createWriter(File file) |
void |
BtreeIndexRecordWriter.flush() |
long |
BtreeIndexRecordWriter.getDiskSize() |
long |
BtreeIndexRecordWriter.getSize() |
ClonableDataStream |
BtreeRecordResult.getStream() |
void |
BtreeIndexRecordWriter.openWriter() |
RecordIterator |
BtreeIndexRecordWriter.readAllRecords() |
RecordIterator |
BtreeIndexRecordWriter.readAllRecords(int limit) |
RecordResult |
BtreeIndexRecordWriter.readRecord(UUIDKey documentId) |
void |
BtreeIndexRecordWriter.removeRecord(UUIDKey documentId) |
void |
BtreeIndexRecordWriter.updateRecord(UUIDKey documentId,
ClonableDataStream dataStream) |
void |
BtreeIndexRecordWriter.writeRecord(UUIDKey documentId,
ClonableDataStream dataStream) |
Modifier and Type | Method and Description |
---|---|
SimpleEntity |
EntityBagImpl.addEntity(SimpleEntity entity) |
void |
EntityBagImpl.ensureIndex(CompositeIndexField indexField,
boolean isUnique,
IndexField... valueFields) |
void |
EntityBagImpl.ensureIndex(IndexField indexField,
boolean isUnique,
IndexField... valueFields) |
QueryExecutor |
EntityBagImpl.find(CompositeQueryField queryFields,
SortParameter... params) |
QueryExecutor |
EntityBagImpl.find(QueryBuilder queryBuilder) |
QueryExecutor |
EntityBagImpl.find(QueryField queryField,
SortParameter... params) |
void |
EntityBagImpl.flush() |
long |
EntityBagImpl.getDiskSize() |
QueryResult |
EntityBagImpl.getEntities() |
QueryResult |
EntityBagImpl.getEntities(int max) |
SimpleEntity |
EntityBagImpl.getEntity(String entityId) |
List<String> |
EntityBagImpl.getIndexNames() |
long |
EntityBagImpl.getSize() |
void |
EntityBagImpl.removeEntity(SimpleEntity entity) |
void |
EntityBagImpl.removeEntity(String entityId) |
void |
EntityBagImpl.removeIndex(String indexKeyName) |
SimpleEntity |
EntityBagImpl.updateEntity(SimpleEntity entity) |
Constructor and Description |
---|
EntityBagImpl(String instanceId,
String name) |
EntityBagImpl(String instanceId,
String name,
UserSession userSession) |
Modifier and Type | Class and Description |
---|---|
class |
RecordStoreInUseException |
Modifier and Type | Method and Description |
---|---|
Index |
IndexManagerImpl.createIndex(String bagName,
CompositeIndexField compositeIndexFields,
boolean unique,
IndexField... values) |
Index |
IndexManagerImpl.createIndex(String bagName,
IndexField indexField,
boolean unique,
IndexField... valueFields) |
void |
IndexManagerImpl.flush() |
void |
IndexManagerImpl.flush(String bagName) |
Index |
IndexManagerImpl.getBestMatchingIndex(String bagName,
Set<String> fields) |
Index |
IndexManagerImpl.getIndex(String bagName,
String keyName) |
Map<String,Index> |
IndexManagerImpl.getIndexes(String bagName) |
IndexManager |
IndexManagerFactoryImpl.getIndexManager(String instanceId) |
void |
IndexManagerImpl.removeIndex(String bagName,
String keyName) |
void |
IndexManagerImpl.shutdownIndexes() |
void |
IndexManagerFactoryImpl.shutdownIndexes() |
Modifier and Type | Method and Description |
---|---|
QueryResult |
QueryExecutorImpl.execute() |
Modifier and Type | Method and Description |
---|---|
static IndexSearchResultIteratorCollection |
DistinctCollectionUtil.distinct(IndexSearchResultIteratorCollection collection) |
IndexSearchResultIteratorCollection |
BlockMerger.mergeIterators(IndexSearchResultIteratorCollection mergeInto,
IndexSearchResultIteratorCollection... results) |
Modifier and Type | Method and Description |
---|---|
IndexSearchResultIteratorCollection |
AndBlockMerger.mergeIterators(IndexSearchResultIteratorCollection mergeInto,
IndexSearchResultIteratorCollection... results) |
Modifier and Type | Method and Description |
---|---|
void |
Writer.closeWriter() |
void |
TransactionalRecordWriter.closeWriter() |
void |
FSWriter.closeWriter() |
RecordWriter |
TransactionalRecordWriterFactory.createWriter(File file) |
void |
TransactionalRecordWriter.flush() |
long |
Writer.getDiskSize() |
long |
TransactionalRecordWriter.getDiskSize() |
long |
FSWriter.getDiskSize() |
ClonableDataStream |
RecordResultImpl.getStream() |
void |
TransactionalRecordWriter.openWriter() |
RecordResult |
TransactionalRecordWriter.readRecord(UUIDKey documentId) |
void |
TransactionalRecordWriter.removeRecord(UUIDKey documentId) |
void |
TransactionalRecordWriter.updateRecord(UUIDKey documentId,
ClonableDataStream dataStream) |
void |
TransactionalRecordWriter.writeRecord(UUIDKey documentId,
ClonableDataStream dataStream) |
Copyright © 2015. All rights reserved.