|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.mymed.controller.core.manager.storage.StorageManager
com.mymed.controller.core.manager.storage.GeoLocStorageManager
public class MyJamStorageManager
Storage manager created ad-hoc for myJam application.
Field Summary | |
---|---|
static int |
maxNumColumns
|
Fields inherited from interface com.mymed.controller.core.manager.storage.IStorageManager |
---|
consistencyOnRead, consistencyOnWrite |
Constructor Summary | |
---|---|
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 |
Method Summary | |
---|---|
int |
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[]> |
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[]> |
getLastN(java.lang.String tableName,
java.lang.String primaryKey,
java.lang.Integer n)
Gets the first n columns of the given CF row. |
void |
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 |
insertColumn(java.lang.String tableName,
java.lang.String primaryKey,
java.lang.String columnName,
byte[] value)
Update the value of a Simple Column |
void |
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 |
insertExpiringColumn(java.lang.String tableName,
java.lang.String primaryKey,
byte[] columnName,
byte[] value,
long timestamp,
int expiringTime)
|
void |
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 |
insertSuperColumn(java.lang.String tableName,
java.lang.String primaryKey,
java.lang.String superColumn,
java.lang.String columnName,
byte[] value)
Update the value of a Super Column |
void |
removeAll(java.lang.String tableName,
java.lang.String key)
Remove an entry in the columnFamily |
void |
removeColumn(java.lang.String tableName,
java.lang.String primaryKey,
byte[] superColumn,
byte[] column)
Remove a specific column defined by the columnName |
void |
removeColumn(java.lang.String tableName,
java.lang.String key,
java.lang.String columnName)
Remove a specific column defined by the columnName |
java.util.Map<java.lang.String,java.util.Map<byte[],byte[]>> |
selectAll(java.lang.String tableName,
java.util.List<java.lang.String> primaryKeys)
Select all on a list of rows. |
java.util.Map<byte[],byte[]> |
selectAll(java.lang.String tableName,
java.lang.String primaryKey)
Get the value of a column family |
byte[] |
selectColumn(java.lang.String tableName,
java.lang.String primaryKey,
byte[] superColumn,
byte[] column)
Selects a column in a CF. |
ExpColumnBean |
selectExpiringColumn(java.lang.String tableName,
java.lang.String primaryKey,
byte[] superColumn,
byte[] column)
Returns the expiring column, with the timestamp and the TTL. |
java.util.Map<byte[],byte[]> |
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[]> |
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[],java.util.Map<byte[],byte[]>> |
selectSCRange(java.lang.String tableName,
java.util.List<java.lang.String> primaryKeys,
byte[] startColumn,
byte[] stopColumn)
Used in myJam to perform geographical range queries. |
Methods inherited from class com.mymed.controller.core.manager.storage.StorageManager |
---|
countColumns, getWrapper, insertSuperSlice, removeSuperColumn, selectColumn, selectList |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface com.mymed.controller.core.manager.storage.IStorageManager |
---|
countColumns, insertSuperSlice, removeSuperColumn, selectColumn, selectList |
Field Detail |
---|
public static final int maxNumColumns
Constructor Detail |
---|
public MyJamStorageManager() throws InternalBackEndException
IOBackEndException
InternalBackEndException
public MyJamStorageManager(WrapperConfiguration conf) throws InternalBackEndException
type
- Type of DHTClient usedconf
- The configuration of the transport layer
IOBackEndException
InternalBackEndException
Method Detail |
---|
public void insertSlice(java.lang.String tableName, java.lang.String primaryKey, java.util.Map<java.lang.String,byte[]> args) throws InternalBackEndException
StorageManager
insertSlice
in interface IStorageManager
insertSlice
in class StorageManager
tableName
- the name of the Table/ColumnFamilyprimaryKey
- the ID of the entryargs
- All columnName and the their value
InternalBackEndException
public byte[] selectColumn(java.lang.String tableName, java.lang.String primaryKey, byte[] superColumn, byte[] column) throws IOBackEndException, InternalBackEndException
selectColumn
in interface IMyJamStorageManager
tableName
- primaryKey
- superColumn
- column
-
ServiceManagerException
IOBackEndException
InternalBackEndException
public ExpColumnBean selectExpiringColumn(java.lang.String tableName, java.lang.String primaryKey, byte[] superColumn, byte[] column) throws IOBackEndException, InternalBackEndException
selectExpiringColumn
in interface IMyJamStorageManager
tableName
- Name of the CF.primaryKey
- The row key.superColumn
- The SuperColumn name, can be put safely to null if is a CF, but is
compulsory if is a SuperCF.column
- The Column name.
ServiceManagerException
IOBackEndException
- The column is not present.
InternalBackEndException
public void insertColumn(java.lang.String tableName, java.lang.String primaryKey, java.lang.String columnName, byte[] value) throws InternalBackEndException
StorageManager
insertColumn
in interface IStorageManager
insertColumn
in class StorageManager
tableName
- the name of the Table/ColumnFamilyprimaryKey
- the ID of the entrycolumnName
- the name of the columnvalue
- the value updated
InternalBackEndException
public void insertColumn(java.lang.String tableName, java.lang.String primaryKey, byte[] columnName, byte[] value) throws InternalBackEndException
IMyJamStorageManager
insertColumn
in interface IMyJamStorageManager
tableName
- Name of the CF.primaryKey
- Row key.columnName
- Column name.value
- Column value.
InternalBackEndException
public void insertExpiringColumn(java.lang.String tableName, java.lang.String primaryKey, byte[] columnName, byte[] value, long timestamp, int expiringTime) throws InternalBackEndException
InternalBackEndException
public void insertSuperColumn(java.lang.String tableName, java.lang.String primaryKey, java.lang.String superColumn, java.lang.String columnName, byte[] value) throws InternalBackEndException
StorageManager
insertSuperColumn
in interface IStorageManager
insertSuperColumn
in class StorageManager
tableName
- the name of the Table/ColumnFamilyprimaryKey
- the ID of the entrysuperColumn
- the ID of the superColumncolumnName
- the name of the columnvalue
- the value updated
InternalBackEndException
public void insertExpiringColumn(java.lang.String tableName, java.lang.String key, byte[] superColumn, byte[] columnName, byte[] value, long timestamp, int expiringTime) throws InternalBackEndException
IMyJamStorageManager
insertExpiringColumn
in interface IMyJamStorageManager
tableName
- Name of the CF.superColumn
- SuperColumn name, null if insertion is done on a CF.columnName
- Column name.value
- Column value.timestamp
- Timestamp in microseconds since 1 Jenuary 1970.expiringTime
- TTL in seconds.
InternalBackEndException
public java.util.Map<byte[],byte[]> selectAll(java.lang.String tableName, java.lang.String primaryKey) throws IOBackEndException, InternalBackEndException
StorageManager
selectAll
in interface IStorageManager
selectAll
in class StorageManager
tableName
- the name of the Table/ColumnFamilyprimaryKey
- the ID of the entry
IOBackEndException
InternalBackEndException
public java.util.Map<java.lang.String,java.util.Map<byte[],byte[]>> selectAll(java.lang.String tableName, java.util.List<java.lang.String> primaryKeys) throws IOBackEndException, InternalBackEndException
IMyJamStorageManager
selectAll
in interface IMyJamStorageManager
tableName
- Name of the CF.primaryKeys
- List of row keys.
IOBackEndException
InternalBackEndException
public java.util.Map<byte[],byte[]> selectRange(java.lang.String tableName, java.lang.String primaryKey, java.util.List<java.lang.String> columnNames) throws IOBackEndException, InternalBackEndException
StorageManager
selectRange
in interface IStorageManager
selectRange
in class StorageManager
tableName
- the name of the Table/ColumnFamilyprimaryKey
- the ID of the entrycolumnNames
- the name of the columns to return the values
IOBackEndException
InternalBackEndException
public java.util.Map<byte[],byte[]> selectRange(java.lang.String tableName, java.lang.String primaryKey, byte[] startColumn, byte[] stopColumn, int maxNum) throws IOBackEndException, InternalBackEndException
selectRange
in interface IMyJamStorageManager
tableName
- Name of the CF.primaryKey
- Row key.startColumn
- Start column (columns are ordered).stopColumn
- Stop column.maxNum
- Maximum number of returned values,
IOBackEndException
InternalBackEndException
public java.util.Map<byte[],byte[]> getLastN(java.lang.String tableName, java.lang.String primaryKey, java.lang.Integer n) throws IOBackEndException, InternalBackEndException
getLastN
in interface IMyJamStorageManager
tableName
- ColumnFamily.primaryKey
- Key of the row.n
- Number of returned columns (at most.)
IOBackEndException
InternalBackEndException
public java.util.Map<byte[],byte[]> getFrom(java.lang.String tableName, java.lang.String primaryKey, byte[] start) throws IOBackEndException, InternalBackEndException
getFrom
in interface IMyJamStorageManager
tableName
- ColumnFamily.primaryKey
- Key of the row.start
- Starting value.
IOBackEndException
InternalBackEndException
public java.util.Map<byte[],java.util.Map<byte[],byte[]>> selectSCRange(java.lang.String tableName, java.util.List<java.lang.String> primaryKeys, byte[] startColumn, byte[] stopColumn) throws IOBackEndException, InternalBackEndException
selectSCRange
in interface IMyJamStorageManager
tableName
- primaryKey
- startColumn
- stopColumn
-
ServiceManagerException
IOBackEndException
InternalBackEndException
public int countColumns(java.lang.String tableName, java.lang.String primaryKey, byte[] superColumn) throws IOBackEndException, InternalBackEndException
IMyJamStorageManager
countColumns
in interface IMyJamStorageManager
tableName
- Name of the CF.primaryKey
- Row key.superColumn
- Number of columns ().
IOBackEndException
InternalBackEndException
public void removeColumn(java.lang.String tableName, java.lang.String key, java.lang.String columnName) throws InternalBackEndException
removeColumn
in interface IStorageManager
removeColumn
in class StorageManager
keyspace
- columnFamily
- key
- columnName
-
ServiceManagerException
InternalBackEndException
java.io.UnsupportedEncodingException
public void removeAll(java.lang.String tableName, java.lang.String key) throws InternalBackEndException
StorageManager
removeAll
in interface IStorageManager
removeAll
in class StorageManager
InternalBackEndException
public void removeColumn(java.lang.String tableName, java.lang.String primaryKey, byte[] superColumn, byte[] column) throws InternalBackEndException
removeColumn
in interface IMyJamStorageManager
keyspace
- columnFamily
- key
- columnName
-
ServiceManagerException
InternalBackEndException
java.io.UnsupportedEncodingException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |