|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of InternalBackEndException in com.mymed.controller.core.manager |
---|
Methods in com.mymed.controller.core.manager that throw InternalBackEndException | |
---|---|
AbstractMBean |
AbstractManager.introspection(java.lang.Class<? extends AbstractMBean> clazz,
java.util.Map<byte[],byte[]> args)
Introspection |
Uses of InternalBackEndException in com.mymed.controller.core.manager.application |
---|
Methods in com.mymed.controller.core.manager.application that throw InternalBackEndException | |
---|---|
void |
ApplicationManager.create(MUserBean user)
|
void |
IApplicationManager.create(MUserBean user)
|
void |
ApplicationManager.delete(java.lang.String id)
|
void |
IApplicationManager.delete(java.lang.String id)
|
MUserBean |
ApplicationManager.read(java.lang.String id)
|
MUserBean |
IApplicationManager.read(java.lang.String id)
|
void |
ApplicationManager.update(MUserBean user)
|
void |
IApplicationManager.update(MUserBean user)
|
Constructors in com.mymed.controller.core.manager.application that throw InternalBackEndException | |
---|---|
ApplicationManager()
|
|
ApplicationManager(IStorageManager storageManager)
|
Uses of InternalBackEndException in com.mymed.controller.core.manager.authentication |
---|
Methods in com.mymed.controller.core.manager.authentication that throw InternalBackEndException | |
---|---|
MUserBean |
AuthenticationManager.create(MUserBean user,
MAuthenticationBean authentication)
|
MUserBean |
IAuthenticationManager.create(MUserBean user,
MAuthenticationBean authentication)
create myMed user profile |
MUserBean |
AuthenticationManager.read(java.lang.String login,
java.lang.String password)
|
MUserBean |
IAuthenticationManager.read(java.lang.String login,
java.lang.String password)
authentication |
void |
AuthenticationManager.update(java.lang.String id,
MAuthenticationBean authentication)
|
void |
IAuthenticationManager.update(java.lang.String id,
MAuthenticationBean authentication)
update myMed user profile : Authentication Table (password) |
Constructors in com.mymed.controller.core.manager.authentication that throw InternalBackEndException | |
---|---|
AuthenticationManager()
|
|
AuthenticationManager(StorageManager storageManager)
|
Uses of InternalBackEndException in com.mymed.controller.core.manager.buddy |
---|
Methods in com.mymed.controller.core.manager.buddy that throw InternalBackEndException | |
---|---|
void |
IBuddiesManager.delete(java.lang.String mymedID,
java.lang.String buddyID)
remove a buddy from the buddyList |
void |
BuddiesManager.delete(java.lang.String mymedID,
java.lang.String buddyID)
|
java.util.List<java.util.Map<java.lang.String,java.lang.String>> |
IBuddiesManager.read(java.lang.String mymedID)
read the list |
java.util.List<java.util.Map<java.lang.String,java.lang.String>> |
BuddiesManager.read(java.lang.String mymedID)
|
void |
IBuddiesManager.update(java.lang.String mymedID,
java.lang.String buddyID)
add new buddy |
void |
BuddiesManager.update(java.lang.String mymedID,
java.lang.String buddyID)
|
Uses of InternalBackEndException in com.mymed.controller.core.manager.connection |
---|
Methods in com.mymed.controller.core.manager.connection that throw InternalBackEndException | |
---|---|
void |
IConnection.open()
Open the connection to the database |
void |
Connection.open()
|
Uses of InternalBackEndException in com.mymed.controller.core.manager.geolocation |
---|
Methods in com.mymed.controller.core.manager.geolocation that throw InternalBackEndException | |
---|---|
MSearchBean |
GeoLocationManager.create(java.lang.String applicationId,
java.lang.String itemType,
java.lang.String userLogin,
int latitude,
int longitude,
java.lang.String value,
int permTime)
Insert a new located item into the database. |
void |
GeoLocationManager.delete(java.lang.String applicationId,
java.lang.String itemType,
long locationId,
java.lang.String itemId)
Deletes one located item. |
java.util.List<MSearchBean> |
GeoLocationManager.read(java.lang.String applicationId,
java.lang.String itemType,
int latitude,
int longitude,
int radius)
Search located items in a circular region specified by latitude, longitude and radius. |
MSearchBean |
GeoLocationManager.read(java.lang.String applicationId,
java.lang.String itemType,
long locationId,
java.lang.String itemId)
Returns the MSearchBean or throws an exception if it is not present. |
Constructors in com.mymed.controller.core.manager.geolocation that throw InternalBackEndException | |
---|---|
GeoLocationManager()
|
|
GeoLocationManager(MyJamStorageManager storageManager)
|
Uses of InternalBackEndException in com.mymed.controller.core.manager.interaction |
---|
Methods in com.mymed.controller.core.manager.interaction that throw InternalBackEndException | |
---|---|
void |
InteractionManager.create(MInteractionBean interaction)
|
void |
IInteractionManager.create(MInteractionBean interaction)
|
void |
InteractionManager.delete(java.lang.String interactionID)
|
void |
IInteractionManager.delete(java.lang.String interactionID)
|
MInteractionBean |
InteractionManager.read(java.lang.String interactionID)
|
MInteractionBean |
IInteractionManager.read(java.lang.String interactionID)
|
void |
InteractionManager.update(MInteractionBean interaction)
|
void |
IInteractionManager.update(MInteractionBean interaction)
|
Constructors in com.mymed.controller.core.manager.interaction that throw InternalBackEndException | |
---|---|
InteractionManager()
|
|
InteractionManager(StorageManager storageManager)
|
Uses of InternalBackEndException in com.mymed.controller.core.manager.interaction.old |
---|
Methods in com.mymed.controller.core.manager.interaction.old that throw InternalBackEndException | |
---|---|
void |
InteractionManager.create(MInteractionBean interaction)
|
void |
IInteractionManager.create(MInteractionBean interaction)
|
void |
InteractionManager.delete(java.lang.String interactionID)
|
void |
IInteractionManager.delete(java.lang.String interactionID)
|
MInteractionBean |
InteractionManager.read(java.lang.String interactionID)
|
MInteractionBean |
IInteractionManager.read(java.lang.String interactionID)
|
void |
InteractionManager.update(MInteractionBean interaction)
|
void |
IInteractionManager.update(MInteractionBean interaction)
|
Constructors in com.mymed.controller.core.manager.interaction.old that throw InternalBackEndException | |
---|---|
InteractionManager()
|
|
InteractionManager(StorageManager storageManager)
|
Uses of InternalBackEndException in com.mymed.controller.core.manager.myjam |
---|
Methods in com.mymed.controller.core.manager.myjam that throw InternalBackEndException | |
---|---|
void |
MyJamManager.deleteReport(java.lang.String reportId)
|
java.util.List<java.lang.String> |
MyJamManager.getActiveReport(java.lang.String userId)
|
java.util.List<MFeedBackBean> |
MyJamManager.getFeedbacks(java.lang.String reportId)
Returns an integer array with: - The number of negative feedbacks with index 0. - The number of positive feedbacks with index 1. |
MReportBean |
MyJamManager.getReport(java.lang.String reportId)
|
java.util.List<MReportBean> |
MyJamManager.getUpdates(java.lang.String reportId,
long timestamp)
Returns a list of updates. |
void |
MyJamManager.insertFeedback(java.lang.String reportId,
java.lang.String updateId,
MFeedBackBean feedback)
|
MReportBean |
MyJamManager.insertReport(MReportBean report,
int latitude,
int longitude)
Insert a new report on the DB |
MReportBean |
MyJamManager.insertUpdate(java.lang.String reportId,
MReportBean update)
|
java.util.List<MSearchBean> |
MyJamManager.searchReports(int latitude,
int longitude,
int radius)
Returns a list of reports, located in the circular area defined by latitude, longitude and radius. |
Uses of InternalBackEndException in com.mymed.controller.core.manager.position |
---|
Methods in com.mymed.controller.core.manager.position that throw InternalBackEndException | |
---|---|
MPositionBean |
IPositionManager.create(MPositionBean user)
|
MPositionBean |
PositionManager.create(MPositionBean position)
Setup a new user profile into the database |
MPositionBean |
IPositionManager.read(java.lang.String userID)
|
MPositionBean |
PositionManager.read(java.lang.String userID)
|
void |
IPositionManager.update(MPositionBean position)
|
void |
PositionManager.update(MPositionBean position)
|
Constructors in com.mymed.controller.core.manager.position that throw InternalBackEndException | |
---|---|
PositionManager()
|
|
PositionManager(StorageManager storageManager)
|
Uses of InternalBackEndException in com.mymed.controller.core.manager.profile |
---|
Methods in com.mymed.controller.core.manager.profile that throw InternalBackEndException | |
---|---|
MUserBean |
ProfileManager.create(MUserBean user)
Setup a new user profile into the database |
MUserBean |
IProfileManager.create(MUserBean user)
Setup a new user profile into the database |
void |
ProfileManager.delete(java.lang.String id)
|
void |
IProfileManager.delete(java.lang.String id)
Delete an existing user |
MUserBean |
ProfileManager.read(java.lang.String id)
|
MUserBean |
IProfileManager.read(java.lang.String id)
|
MUserBean |
ProfileManager.update(MUserBean user)
|
MUserBean |
IProfileManager.update(MUserBean user)
Update the profile of an user into the database |
Constructors in com.mymed.controller.core.manager.profile that throw InternalBackEndException | |
---|---|
ProfileManager()
|
|
ProfileManager(IStorageManager storageManager)
|
Uses of InternalBackEndException in com.mymed.controller.core.manager.pubsub |
---|
Methods in com.mymed.controller.core.manager.pubsub that throw InternalBackEndException | |
---|---|
void |
PubSubManager.create(java.lang.String application,
java.lang.String predicate,
MUserBean subscriber)
SUBSCRIBE |
void |
IPubSubManager.create(java.lang.String application,
java.lang.String predicate,
MUserBean publisher)
Insert a new Predicate in the dataBase - SUBSCRIBE |
void |
PubSubManager.create(java.lang.String application,
java.lang.String predicate,
java.lang.String subPredicate,
MUserBean publisher,
java.util.List<MDataBean> dataList)
PUBLISH |
void |
IPubSubManager.create(java.lang.String application,
java.lang.String predicate,
java.lang.String subPredicate,
MUserBean publisher,
java.util.List<MDataBean> dataList)
Insert a new Predicate in the dataBase - PUBLISH |
void |
PubSubManager.delete(java.lang.String application,
java.lang.String predicate,
MUserBean user)
|
void |
IPubSubManager.delete(java.lang.String application,
java.lang.String predicate,
MUserBean user)
Delete an existing predicate |
java.util.List<java.util.Map<java.lang.String,java.lang.String>> |
PubSubManager.read(java.lang.String application,
java.lang.String predicate)
FIND |
java.util.List<java.util.Map<java.lang.String,java.lang.String>> |
IPubSubManager.read(java.lang.String application,
java.lang.String predicate)
|
java.util.List<java.util.Map<java.lang.String,java.lang.String>> |
PubSubManager.read(java.lang.String application,
java.lang.String predicate,
java.lang.String userID)
FIND - GET DETAILS |
java.util.List<java.util.Map<java.lang.String,java.lang.String>> |
IPubSubManager.read(java.lang.String application,
java.lang.String predicate,
java.lang.String userID)
Get the DataList Entry related to aplication+predicate+userID |
Constructors in com.mymed.controller.core.manager.pubsub that throw InternalBackEndException | |
---|---|
PubSubManager()
|
|
PubSubManager(IStorageManager storageManager)
|
Uses of InternalBackEndException in com.mymed.controller.core.manager.registration |
---|
Constructors in com.mymed.controller.core.manager.registration that throw InternalBackEndException | |
---|---|
RegistrationManager()
|
Uses of InternalBackEndException in com.mymed.controller.core.manager.reputation.db.facade |
---|
Methods in com.mymed.controller.core.manager.reputation.db.facade that throw InternalBackEndException | |
---|---|
void |
TransactionManager.commit()
|
void |
TransactionManager.deleteRow(java.lang.String nameOfColumnFamily,
java.lang.String key)
|
void |
CassandraQueryFacade.deleteRow(java.lang.String nameOfColumnFamily,
java.lang.String key)
This method deletes a row of a columnfamily |
void |
CassandraQueryFacade.flush()
|
java.util.List<java.lang.Object> |
TransactionManager.getListOfObjectFromListOfKeys(java.util.List<java.lang.String> keys,
java.lang.String columnFamilyName)
|
java.lang.Object |
TransactionManager.loadRow(java.lang.String nameOfColumnFamily,
java.lang.String key)
|
java.util.List<java.lang.Object> |
TransactionManager.loadTable(java.lang.String columnFamilyName)
|
java.util.List<java.lang.String> |
TransactionManager.readSuperColummFamily(java.lang.String nameOfSuperColumnFamily,
java.lang.String key)
|
java.util.List<java.lang.String> |
CassandraQueryFacade.readSuperColummFamily(java.lang.String nameOfSuperColumnFamily,
java.lang.String key)
|
Uses of InternalBackEndException in com.mymed.controller.core.manager.reputation.db.table.facade |
---|
Methods in com.mymed.controller.core.manager.reputation.db.table.facade that throw InternalBackEndException | |
---|---|
void |
DbTableAdapter.commit()
|
void |
DbTableAdapter.deleteAggregation(java.lang.String idAggregation)
|
void |
VerdictAggregationFacade.deleteAggregation(java.lang.String idAggreagation)
this method delete a previously created VerdictAggregation |
void |
VerdictFacade.deleteVerdictAggregationList(java.lang.String idAggregation)
|
java.util.Collection<VerdictAggregation> |
VerdictAggregationFacade.getAllRecords()
it returns the collection of all entries of the table VerdictAggregation. |
java.util.Collection<UserApplicationProducer> |
UserApplicationProducerFacade.getAllRecords()
it returns the collection of all entries of the table UserServiceProvider. |
java.util.Collection<UserApplicationConsumer> |
UserApplicationConsumerFacade.getAllRecords()
it returns the collection of all entries of the table UserApplicationConsumer. |
java.util.Collection<Verdict> |
VerdictFacade.getAllRecords()
it returns all the entries of the table AtomicInteraction. |
java.util.Collection<UserApplicationProducer> |
DbTableAdapter.getAllRecordsUserApplicationProducer()
|
java.util.Collection<Verdict> |
DbTableAdapter.getAllRecordsVerdict()
|
java.util.Collection<VerdictAggregation> |
DbTableAdapter.getAllRecordsVerdictAggregation()
|
java.util.Collection<UserApplicationConsumer> |
DbTableAdapter.getAllUserApplicationConsumer()
|
java.util.Collection<Verdict> |
DbTableAdapter.getConsumerVerdictByApplication(java.lang.String idApplicationReputation)
|
java.util.Collection<VerdictAggregation> |
DbTableAdapter.getListOfAggregationByVerdict(java.lang.String idVerdict)
|
java.util.Collection<VerdictAggregation> |
VerdictAggregationFacade.getListOfAggregationByVerdict(java.lang.String idVerdict)
it returns the list of all aggregations to which a given verdict belongs |
java.util.Collection<Verdict> |
DbTableAdapter.getProducerVerdictByApplication(java.lang.String idApplicationReputation)
|
VerdictAggregation |
VerdictAggregationFacade.getRecordById(java.lang.String idAggregation)
it returns the entry of the table VerdictAggregation having the specified id. |
UserApplicationProducer |
UserApplicationProducerFacade.getRecordById(java.lang.String idUser,
java.lang.String idApp)
it returns the entry of the table UserServiceProvider having the specified id. |
UserApplicationConsumer |
UserApplicationConsumerFacade.getRecordById(java.lang.String idUser,
java.lang.String idApp)
it returns the entry of the table UserServiceConsumer having the specified id. |
UserApplicationProducer |
DbTableAdapter.getRecordByIdUserApplicationProducer(java.lang.String idUser,
java.lang.String idApp)
|
java.util.Collection<Verdict> |
VerdictFacade.getRecordsByEvaluatedToConsumerAndDate(java.lang.String idUserServiceConsumer,
java.util.Date LowerBoundFilter,
java.util.Date UpperBoundFilter)
this method returns the collection of all atomic interaction referred to a given idUserService which is a consumer (so referred to the table UserServiceConsumer) whose feedback have been provided to the consumer (which means that the field recipientOfTheFeedback corresponds to CONSUMER) and whose timestamp is within the considered temporal range. |
java.util.Collection<Verdict> |
VerdictFacade.getRecordsByEvaluatedToProducerAndDate(java.lang.String idUserService,
java.util.Date LowerBoundFilter,
java.util.Date UpperBoundFilter)
this method returns the collection of all atomic interaction referred to a given idUserService which is a producer (so referred to the table UserServiceProvider) whose feedback have been provided to the producer (which means that the field recipientOfTheFeedback corresponds to PRODUCER) and whose timestamp is within the considered temporal range. |
UserApplicationConsumer |
DbTableAdapter.getRecordUserApplicationConsumerById(java.lang.String idUser,
java.lang.String idApp)
|
VerdictAggregation |
DbTableAdapter.getRecordVerdictAggregationById(java.lang.String idAggregation)
|
java.util.Collection<Verdict> |
DbTableAdapter.getVerdictByUserReputation(java.lang.String idUserReputation)
|
java.util.Collection<Verdict> |
DbTableAdapter.getVerdictsByEvaluatedToConsumerAndDate(java.lang.String idUserServiceConsumer,
java.util.Date LowerBoundFilter,
java.util.Date UpperBoundFilter)
|
java.util.Collection<Verdict> |
DbTableAdapter.getVerdictsByEvaluatedToProducerAndDate(java.lang.String idUserService,
java.util.Date LowerBoundFilter,
java.util.Date UpperBoundFilter)
|
java.util.Collection<Verdict> |
DbTableAdapter.getVerdictsByIdAggregation(java.lang.String idAggr)
|
java.util.Collection<Verdict> |
VerdictFacade.getVerdictsByIdAggregation(java.lang.String idAggregation)
it returns the collection of all verdicts belonging to a given aggregation |
void |
VerdictFacade.persist(Verdict tc)
this methods persists the object given in input in the database (it could do an INSERT statement or an UPDATE statement depending on the fact that the object given in input has a new id or not). |
void |
DbTableAdapter.persistUserApplicationConsumer(UserApplicationConsumer u)
|
void |
DbTableAdapter.persistUserApplicationProducer(UserApplicationProducer u)
|
void |
DbTableAdapter.persistVerdict(Verdict tc)
|
void |
DbTableAdapter.persistVerdictAggregation(VerdictAggregation tc)
|
void |
DbTableAdapter.persistVerdictToAggregation(VerdictAggregation va,
Verdict v)
|
Uses of InternalBackEndException in com.mymed.controller.core.manager.reputation.old |
---|
Methods in com.mymed.controller.core.manager.reputation.old that throw InternalBackEndException | |
---|---|
void |
IReputationManager.create(MReputationBean reputation,
java.lang.String id)
|
void |
ReputationManager.create(MReputationBean reputation,
java.lang.String id)
|
MReputationBean |
IReputationManager.read(java.lang.String producerID,
java.lang.String consumerID,
java.lang.String applicationID)
Get the reputation of a publisher related to a given service |
MReputationBean |
ReputationManager.read(java.lang.String producerID,
java.lang.String consumerID,
java.lang.String applicationID)
|
void |
IReputationManager.update(MReputationBean reputation,
java.lang.String id)
Update the reputation of a publisher related to a given service |
void |
ReputationManager.update(MReputationBean reputation,
java.lang.String id)
|
Constructors in com.mymed.controller.core.manager.reputation.old that throw InternalBackEndException | |
---|---|
ReputationManager()
|
|
ReputationManager(StorageManager storageManager)
|
Uses of InternalBackEndException in com.mymed.controller.core.manager.session |
---|
Methods in com.mymed.controller.core.manager.session that throw InternalBackEndException | |
---|---|
void |
SessionManager.create(MSessionBean sessionBean)
|
void |
ISessionManager.create(MSessionBean sessionBean)
Login |
void |
SessionManager.create(java.lang.String userID,
java.lang.String ip)
Deprecated. |
void |
ISessionManager.create(java.lang.String userID,
java.lang.String ip)
Deprecated. |
void |
SessionManager.delete(java.lang.String sessionID)
|
void |
ISessionManager.delete(java.lang.String userID)
logout |
MSessionBean |
SessionManager.read(java.lang.String sessionID)
|
MSessionBean |
ISessionManager.read(java.lang.String userID)
|
void |
SessionManager.update(MSessionBean session)
|
void |
ISessionManager.update(MSessionBean session)
|
Constructors in com.mymed.controller.core.manager.session that throw InternalBackEndException | |
---|---|
SessionManager()
|
|
SessionManager(StorageManager storageManager)
|
Uses of InternalBackEndException in com.mymed.controller.core.manager.storage |
---|
Methods in com.mymed.controller.core.manager.storage that throw InternalBackEndException | |
---|---|
int |
IStorageManager.countColumns(java.lang.String tableName,
java.lang.String key)
Count columns in record |
int |
StorageManager.countColumns(java.lang.String tableName,
java.lang.String key)
Count columns in record |
int |
MyJamStorageManager.countColumns(java.lang.String tableName,
java.lang.String primaryKey,
byte[] superColumn)
|
int |
IMyJamStorageManager.countColumns(java.lang.String tableName,
java.lang.String primaryKey,
byte[] superColumn)
Counts the number of colums of a given row or SuperColumn. |
java.util.Map<byte[],byte[]> |
MyJamStorageManager.getFrom(java.lang.String tableName,
java.lang.String primaryKey,
byte[] start)
Gets the columns which have name following on the given CF row. |
java.util.Map<byte[],byte[]> |
IMyJamStorageManager.getFrom(java.lang.String string,
java.lang.String reportId,
byte[] array)
Gets the columns which have name following on the given CF row. |
java.util.Map<byte[],byte[]> |
MyJamStorageManager.getLastN(java.lang.String tableName,
java.lang.String primaryKey,
java.lang.Integer n)
Gets the first n columns of the given CF row. |
java.util.Map<byte[],byte[]> |
IMyJamStorageManager.getLastN(java.lang.String tableName,
java.lang.String primaryKey,
java.lang.Integer n)
Returns the first n columns of a given CF. |
void |
MyJamStorageManager.insertColumn(java.lang.String tableName,
java.lang.String primaryKey,
byte[] columnName,
byte[] value)
|
void |
IMyJamStorageManager.insertColumn(java.lang.String tableName,
java.lang.String primaryKey,
byte[] columnName,
byte[] value)
Is more general then the method insertColumn of IStorageManager, the name of the column can be something different from a String. |
void |
IStorageManager.insertColumn(java.lang.String tableName,
java.lang.String primaryKey,
java.lang.String columnName,
byte[] value)
Update the value of a Simple Column |
void |
StorageManager.insertColumn(java.lang.String tableName,
java.lang.String key,
java.lang.String columnName,
byte[] value)
Update the value of a Simple Column |
void |
MyJamStorageManager.insertColumn(java.lang.String tableName,
java.lang.String primaryKey,
java.lang.String columnName,
byte[] value)
|
void |
MyJamStorageManager.insertExpiringColumn(java.lang.String tableName,
java.lang.String key,
byte[] superColumn,
byte[] columnName,
byte[] value,
long timestamp,
int expiringTime)
|
void |
IMyJamStorageManager.insertExpiringColumn(java.lang.String tableName,
java.lang.String key,
byte[] superColumn,
byte[] columnName,
byte[] value,
long timestamp,
int expiringTime)
It allows to insert an expiring column. |
void |
MyJamStorageManager.insertExpiringColumn(java.lang.String tableName,
java.lang.String primaryKey,
byte[] columnName,
byte[] value,
long timestamp,
int expiringTime)
|
void |
IStorageManager.insertSlice(java.lang.String tableName,
java.lang.String primaryKey,
java.util.Map<java.lang.String,byte[]> args)
Insert a new entry in the database |
void |
StorageManager.insertSlice(java.lang.String tableName,
java.lang.String primaryKey,
java.util.Map<java.lang.String,byte[]> args)
Insert a new entry in the database |
void |
MyJamStorageManager.insertSlice(java.lang.String tableName,
java.lang.String primaryKey,
java.util.Map<java.lang.String,byte[]> args)
|
void |
IStorageManager.insertSuperColumn(java.lang.String tableName,
java.lang.String key,
java.lang.String superColumn,
java.lang.String columnName,
byte[] value)
Update the value of a Super Column |
void |
StorageManager.insertSuperColumn(java.lang.String tableName,
java.lang.String key,
java.lang.String superColumn,
java.lang.String columnName,
byte[] value)
Update the value of a Super Column |
void |
MyJamStorageManager.insertSuperColumn(java.lang.String tableName,
java.lang.String primaryKey,
java.lang.String superColumn,
java.lang.String columnName,
byte[] value)
|
void |
IStorageManager.insertSuperSlice(java.lang.String superTableName,
java.lang.String key,
java.lang.String superKey,
java.util.Map<java.lang.String,byte[]> args)
Insert a new entry in the database |
void |
StorageManager.insertSuperSlice(java.lang.String superTableName,
java.lang.String key,
java.lang.String superKey,
java.util.Map<java.lang.String,byte[]> args)
Insert a new entry in the database |
void |
IStorageManager.removeAll(java.lang.String tableName,
java.lang.String key)
Remove an entry in the columnFamily |
void |
StorageManager.removeAll(java.lang.String tableName,
java.lang.String key)
Remove an entry in the columnFamily |
void |
MyJamStorageManager.removeAll(java.lang.String tableName,
java.lang.String key)
|
void |
MyJamStorageManager.removeColumn(java.lang.String tableName,
java.lang.String primaryKey,
byte[] superColumn,
byte[] column)
Remove a specific column defined by the columnName |
void |
IMyJamStorageManager.removeColumn(java.lang.String tableName,
java.lang.String primaryKey,
byte[] superColumn,
byte[] column)
Removes the specified column (if present) from the CF. |
void |
IStorageManager.removeColumn(java.lang.String tableName,
java.lang.String key,
java.lang.String columnName)
Remove a specific column defined by the columnName |
void |
StorageManager.removeColumn(java.lang.String tableName,
java.lang.String key,
java.lang.String columnName)
Remove a specific column defined by the columnName |
void |
MyJamStorageManager.removeColumn(java.lang.String tableName,
java.lang.String key,
java.lang.String columnName)
Remove a specific column defined by the columnName |
void |
IStorageManager.removeSuperColumn(java.lang.String tableName,
java.lang.String key,
java.lang.String superColumnName)
|
void |
StorageManager.removeSuperColumn(java.lang.String tableName,
java.lang.String key,
java.lang.String superColumnName)
|
java.util.Map<java.lang.String,java.util.Map<byte[],byte[]>> |
MyJamStorageManager.selectAll(java.lang.String tableName,
java.util.List<java.lang.String> primaryKeys)
|
java.util.Map<java.lang.String,java.util.Map<byte[],byte[]>> |
IMyJamStorageManager.selectAll(java.lang.String tableName,
java.util.List<java.lang.String> primaryKeys)
Select all on a list of rows. |
java.util.Map<byte[],byte[]> |
IStorageManager.selectAll(java.lang.String tableName,
java.lang.String primaryKey)
Get the value of a Column family |
java.util.Map<byte[],byte[]> |
StorageManager.selectAll(java.lang.String tableName,
java.lang.String key)
Get the value of a column family |
java.util.Map<byte[],byte[]> |
MyJamStorageManager.selectAll(java.lang.String tableName,
java.lang.String primaryKey)
|
byte[] |
MyJamStorageManager.selectColumn(java.lang.String tableName,
java.lang.String primaryKey,
byte[] superColumn,
byte[] column)
Selects a column in a CF. |
byte[] |
IMyJamStorageManager.selectColumn(java.lang.String tableName,
java.lang.String primaryKey,
byte[] superColumn,
byte[] column)
Can be used to select columns in both SuperCF and CF. |
byte[] |
IStorageManager.selectColumn(java.lang.String tableName,
java.lang.String primaryKey,
java.lang.String columnName)
Get the value of an entry column |
byte[] |
StorageManager.selectColumn(java.lang.String tableName,
java.lang.String key,
java.lang.String columnName)
Get the value of an entry column |
ExpColumnBean |
MyJamStorageManager.selectExpiringColumn(java.lang.String tableName,
java.lang.String primaryKey,
byte[] superColumn,
byte[] column)
Returns the expiring column, with the timestamp and the TTL. |
ExpColumnBean |
IMyJamStorageManager.selectExpiringColumn(java.lang.String tableName,
java.lang.String primaryKey,
byte[] superColumn,
byte[] column)
Equals to the preceding, but apart from the name-value pair returns also the timestamp and the TTL. |
java.util.List<java.util.Map<byte[],byte[]>> |
IStorageManager.selectList(java.lang.String tableName,
java.lang.String key)
Get the list of values of a Super Column Family |
java.util.List<java.util.Map<byte[],byte[]>> |
StorageManager.selectList(java.lang.String tableName,
java.lang.String key)
Get the value of a column family |
java.util.Map<byte[],byte[]> |
MyJamStorageManager.selectRange(java.lang.String tableName,
java.lang.String primaryKey,
byte[] startColumn,
byte[] stopColumn,
int maxNum)
Selects a range of columns, specifying the extremes. |
java.util.Map<byte[],byte[]> |
IMyJamStorageManager.selectRange(java.lang.String tableName,
java.lang.String primaryKey,
byte[] startColumn,
byte[] stopColumn,
int maxNum)
Returns a map of name-value pairs corresponding to a certain range of columns. |
java.util.Map<byte[],byte[]> |
IStorageManager.selectRange(java.lang.String tableName,
java.lang.String primaryKey,
java.util.List<java.lang.String> columnNames)
Get the values of a range of columns |
java.util.Map<byte[],byte[]> |
StorageManager.selectRange(java.lang.String tableName,
java.lang.String key,
java.util.List<java.lang.String> columnNames)
Get the values of a range of columns |
java.util.Map<byte[],byte[]> |
MyJamStorageManager.selectRange(java.lang.String tableName,
java.lang.String primaryKey,
java.util.List<java.lang.String> columnNames)
|
java.util.Map<byte[],java.util.Map<byte[],byte[]>> |
MyJamStorageManager.selectSCRange(java.lang.String tableName,
java.util.List<java.lang.String> primaryKeys,
byte[] startColumn,
byte[] stopColumn)
Used in myJam to perform geographical range queries. |
java.util.Map<byte[],java.util.Map<byte[],byte[]>> |
IMyJamStorageManager.selectSCRange(java.lang.String tableName,
java.util.List<java.lang.String> primaryKeys,
byte[] startColumn,
byte[] stopColumn)
Select a range of columns on a list of rows. |
Constructors in com.mymed.controller.core.manager.storage that throw InternalBackEndException | |
---|---|
MyJamStorageManager()
Default Constructor: will create a ServiceManger on top of a Cassandra Wrapper |
|
MyJamStorageManager(WrapperConfiguration conf)
/** will create a ServiceManger on top of the WrapperType And use the specific configuration file for the transport layer |
|
StorageManager()
Default Constructor: will create a ServiceManger on top of a Cassandra Wrapper |
|
StorageManager(WrapperConfiguration conf)
will create a ServiceManger on top of the WrapperType And use the specific configuration file for the transport layer |
Uses of InternalBackEndException in com.mymed.model.core.wrappers.cassandra.api07 |
---|
Methods in com.mymed.model.core.wrappers.cassandra.api07 that throw InternalBackEndException | |
---|---|
void |
ICassandraWrapper.batch_mutate(java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.util.List<org.apache.cassandra.thrift.Mutation>>> mutationMap,
org.apache.cassandra.thrift.ConsistencyLevel level)
Execute the specified mutations on the keyspace A Mutation specifies either columns to insert or columns to delete |
void |
CassandraWrapper.batch_mutate(java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.util.List<org.apache.cassandra.thrift.Mutation>>> mutationMap,
org.apache.cassandra.thrift.ConsistencyLevel level)
|
void |
CassandraWrapper.batchMutate(java.util.Map<java.nio.ByteBuffer,java.util.Map<java.lang.String,java.util.List<org.apache.cassandra.thrift.Mutation>>> mutationMap,
org.apache.cassandra.thrift.ConsistencyLevel level)
|
java.lang.String |
ICassandraWrapper.describe_cluster_name()
|
java.lang.String |
CassandraWrapper.describe_cluster_name()
|
org.apache.cassandra.thrift.KsDef |
ICassandraWrapper.describe_keyspace(java.lang.String keySpace)
|
org.apache.cassandra.thrift.KsDef |
CassandraWrapper.describe_keyspace(java.lang.String keySpace)
|
java.util.List<org.apache.cassandra.thrift.KsDef> |
ICassandraWrapper.describe_keyspaces()
|
java.util.List<org.apache.cassandra.thrift.KsDef> |
CassandraWrapper.describe_keyspaces()
|
java.lang.String |
ICassandraWrapper.describe_partitioner()
|
java.lang.String |
CassandraWrapper.describe_partitioner()
|
java.util.List<org.apache.cassandra.thrift.TokenRange> |
ICassandraWrapper.describe_ring(java.lang.String keySpace)
Get the token ring; a map of ranges to host addresses. |
java.util.List<org.apache.cassandra.thrift.TokenRange> |
CassandraWrapper.describe_ring(java.lang.String keySpace)
|
java.lang.String |
ICassandraWrapper.describe_snitch()
|
java.lang.String |
CassandraWrapper.describe_snitch()
|
java.lang.String |
ICassandraWrapper.describe_version()
|
java.lang.String |
CassandraWrapper.describe_version()
|
int |
CassandraWrapper.get_cf_id(java.lang.String keySpaceName,
java.lang.String columnFamilyName)
Retrieve the specified column family id in the given keyspace |
int |
ICassandraWrapper.get_count(java.lang.String key,
org.apache.cassandra.thrift.ColumnParent parent,
org.apache.cassandra.thrift.SlicePredicate predicate,
org.apache.cassandra.thrift.ConsistencyLevel level)
Counts the column present in the column parent within the predicate The method is not O(1). |
int |
CassandraWrapper.get_count(java.lang.String key,
org.apache.cassandra.thrift.ColumnParent parent,
org.apache.cassandra.thrift.SlicePredicate predicate,
org.apache.cassandra.thrift.ConsistencyLevel level)
|
java.util.List<org.apache.cassandra.thrift.KeySlice> |
ICassandraWrapper.get_indexed_slices(org.apache.cassandra.thrift.ColumnParent parent,
org.apache.cassandra.thrift.IndexClause clause,
org.apache.cassandra.thrift.SlicePredicate predicate,
org.apache.cassandra.thrift.ConsistencyLevel level)
Return a list of slices, but uses IndexClause instead of
KeyRange . |
java.util.List<org.apache.cassandra.thrift.KeySlice> |
CassandraWrapper.get_indexed_slices(org.apache.cassandra.thrift.ColumnParent parent,
org.apache.cassandra.thrift.IndexClause clause,
org.apache.cassandra.thrift.SlicePredicate predicate,
org.apache.cassandra.thrift.ConsistencyLevel level)
|
java.util.List<org.apache.cassandra.thrift.KeySlice> |
ICassandraWrapper.get_range_slices(org.apache.cassandra.thrift.ColumnParent parent,
org.apache.cassandra.thrift.SlicePredicate predicate,
org.apache.cassandra.thrift.KeyRange range,
org.apache.cassandra.thrift.ConsistencyLevel level)
Return a list of slices for the keys within the specified KeyRange Note that when using RandomPartitioner, keys are stored in the order of their MD5 hash, making it impossible to get a meaningful range of keys between two endpoints. |
java.util.List<org.apache.cassandra.thrift.KeySlice> |
CassandraWrapper.get_range_slices(org.apache.cassandra.thrift.ColumnParent parent,
org.apache.cassandra.thrift.SlicePredicate predicate,
org.apache.cassandra.thrift.KeyRange range,
org.apache.cassandra.thrift.ConsistencyLevel level)
|
java.util.List<org.apache.cassandra.thrift.ColumnOrSuperColumn> |
ICassandraWrapper.get_slice(java.lang.String key,
org.apache.cassandra.thrift.ColumnParent parent,
org.apache.cassandra.thrift.SlicePredicate predicate,
org.apache.cassandra.thrift.ConsistencyLevel level)
Get the group of columns contained by the column parent specified by the given predicate |
java.util.List<org.apache.cassandra.thrift.ColumnOrSuperColumn> |
CassandraWrapper.get_slice(java.lang.String key,
org.apache.cassandra.thrift.ColumnParent parent,
org.apache.cassandra.thrift.SlicePredicate predicate,
org.apache.cassandra.thrift.ConsistencyLevel level)
|
org.apache.cassandra.thrift.ColumnOrSuperColumn |
ICassandraWrapper.get(java.lang.String key,
org.apache.cassandra.thrift.ColumnPath path,
org.apache.cassandra.thrift.ConsistencyLevel level)
Get the Column or SuperColumn at the given column path |
org.apache.cassandra.thrift.ColumnOrSuperColumn |
CassandraWrapper.get(java.lang.String key,
org.apache.cassandra.thrift.ColumnPath path,
org.apache.cassandra.thrift.ConsistencyLevel level)
|
void |
ICassandraWrapper.insert(java.lang.String key,
org.apache.cassandra.thrift.ColumnParent parent,
org.apache.cassandra.thrift.Column column,
org.apache.cassandra.thrift.ConsistencyLevel level)
Insert a Column consisting of (name, value, timestamp) at the given
ColumnPath.column_family and optional ColumnPath.super_column. |
void |
CassandraWrapper.insert(java.lang.String key,
org.apache.cassandra.thrift.ColumnParent parent,
org.apache.cassandra.thrift.Column column,
org.apache.cassandra.thrift.ConsistencyLevel level)
|
void |
ICassandraWrapper.login(org.apache.cassandra.thrift.AuthenticationRequest authRequest)
Authenticates with the cluster for operations on the specified keyspace using the specified AuthenticationRequest credentials |
void |
CassandraWrapper.login(org.apache.cassandra.thrift.AuthenticationRequest authRequest)
|
java.util.Map<java.nio.ByteBuffer,java.lang.Integer> |
ICassandraWrapper.multiget_count(java.util.List<java.lang.String> keys,
org.apache.cassandra.thrift.ColumnParent parent,
org.apache.cassandra.thrift.SlicePredicate predicate,
org.apache.cassandra.thrift.ConsistencyLevel level)
A combination of multiget_slice and get_count |
java.util.Map<java.nio.ByteBuffer,java.lang.Integer> |
CassandraWrapper.multiget_count(java.util.List<java.lang.String> keys,
org.apache.cassandra.thrift.ColumnParent parent,
org.apache.cassandra.thrift.SlicePredicate predicate,
org.apache.cassandra.thrift.ConsistencyLevel level)
|
java.util.Map<java.nio.ByteBuffer,java.util.List<org.apache.cassandra.thrift.ColumnOrSuperColumn>> |
ICassandraWrapper.multiget_slice(java.util.List<java.lang.String> keys,
org.apache.cassandra.thrift.ColumnParent parent,
org.apache.cassandra.thrift.SlicePredicate predicate,
org.apache.cassandra.thrift.ConsistencyLevel level)
Retrieve slices for column parent and predicate on each of the given keys in parallel |
java.util.Map<java.nio.ByteBuffer,java.util.List<org.apache.cassandra.thrift.ColumnOrSuperColumn>> |
CassandraWrapper.multiget_slice(java.util.List<java.lang.String> keys,
org.apache.cassandra.thrift.ColumnParent parent,
org.apache.cassandra.thrift.SlicePredicate predicate,
org.apache.cassandra.thrift.ConsistencyLevel level)
|
void |
ICassandraWrapper.remove(java.lang.String key,
org.apache.cassandra.thrift.ColumnPath path,
long timeStamp,
org.apache.cassandra.thrift.ConsistencyLevel level)
Remove data from the row specified by key at the granularity
specified by the ColumnPath path , and the given timestamp. |
void |
CassandraWrapper.remove(java.lang.String key,
org.apache.cassandra.thrift.ColumnPath path,
long timeStamp,
org.apache.cassandra.thrift.ConsistencyLevel level)
|
void |
ICassandraWrapper.set_keyspace(java.lang.String keySpace)
Set the keyspace to work on |
void |
CassandraWrapper.set_keyspace(java.lang.String keySpace)
|
java.lang.String |
ICassandraWrapper.system_add_column_family(org.apache.cassandra.thrift.CfDef cfDef)
Adds a column family. |
java.lang.String |
CassandraWrapper.system_add_column_family(org.apache.cassandra.thrift.CfDef cfDef)
|
java.lang.String |
ICassandraWrapper.system_add_keyspace(org.apache.cassandra.thrift.KsDef ksDef)
Creates a new keyspace and any column families defined with it. |
java.lang.String |
CassandraWrapper.system_add_keyspace(org.apache.cassandra.thrift.KsDef ksDef)
|
java.lang.String |
ICassandraWrapper.system_drop_column_family(java.lang.String columnFamily)
Drops a column family. |
java.lang.String |
CassandraWrapper.system_drop_column_family(java.lang.String columnFamily)
|
java.lang.String |
ICassandraWrapper.system_drop_keyspace(java.lang.String keySpace)
Drops a keyspace. |
java.lang.String |
CassandraWrapper.system_drop_keyspace(java.lang.String keySpace)
|
java.lang.String |
ICassandraWrapper.system_update_column_family(org.apache.cassandra.thrift.CfDef columnFamily)
Update the properties of a column family |
java.lang.String |
CassandraWrapper.system_update_column_family(org.apache.cassandra.thrift.CfDef columnFamily)
|
java.lang.String |
ICassandraWrapper.system_update_keyspace(org.apache.cassandra.thrift.KsDef keySpace)
Update the properties of a keyspace |
java.lang.String |
CassandraWrapper.system_update_keyspace(org.apache.cassandra.thrift.KsDef keySpace)
|
void |
ICassandraWrapper.truncate(java.lang.String columnFamily)
Remove all the rows from the given column family |
void |
CassandraWrapper.truncate(java.lang.String columnFamily)
|
Constructors in com.mymed.model.core.wrappers.cassandra.api07 that throw InternalBackEndException | |
---|---|
CassandraWrapper()
Empty constructor to create a normal Cassandra client, with address the machine address, and port the default port |
|
CassandraWrapper(java.lang.String address,
int port)
Create the Cassandra client |
Uses of InternalBackEndException in com.mymed.model.data |
---|
Methods in com.mymed.model.data that throw InternalBackEndException | |
---|---|
java.util.Map<java.lang.String,byte[]> |
AbstractMBean.getAttributeToMap()
|
Uses of InternalBackEndException in com.mymed.model.data.myjam |
---|
Methods in com.mymed.model.data.myjam that throw InternalBackEndException | |
---|---|
java.util.Map<java.lang.String,byte[]> |
MReportBean.getAttributeToMap()
|
Uses of InternalBackEndException in com.mymed.utils |
---|
Methods in com.mymed.utils that throw InternalBackEndException | |
---|---|
static java.lang.String |
MConverter.byteBufferToString(java.nio.ByteBuffer buffer)
Convert a ByteBuffer back into a string |
static java.lang.String |
MConverter.convertStreamToString(java.io.InputStream is,
int length)
Given an InputStream reads the bytes as UTF8 chars and return a String. |
static java.util.List<java.nio.ByteBuffer> |
MConverter.stringToByteBuffer(java.util.List<java.lang.String> list)
Convert a list of strings in a list with the strings converted into ByteBuffer |
static java.nio.ByteBuffer |
MConverter.stringToByteBuffer(java.lang.String string)
Convert a string into a ByteBuffer . |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |