|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.mymed.model.core.wrappers.cassandra.api07.CassandraWrapper
public class CassandraWrapper
Wrapper for the Cassandra API v0.7.
For more info about the API, check the API web page.
Constructor Summary | |
---|---|
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 |
Method Summary | |
---|---|
void |
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 |
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 |
describe_cluster_name()
|
org.apache.cassandra.thrift.KsDef |
describe_keyspace(java.lang.String keySpace)
|
java.util.List<org.apache.cassandra.thrift.KsDef> |
describe_keyspaces()
|
java.lang.String |
describe_partitioner()
|
java.util.List<org.apache.cassandra.thrift.TokenRange> |
describe_ring(java.lang.String keySpace)
Get the token ring; a map of ranges to host addresses. |
java.lang.String |
describe_snitch()
|
java.lang.String |
describe_version()
|
int |
get_cf_id(java.lang.String keySpaceName,
java.lang.String columnFamilyName)
Retrieve the specified column family id in the given keyspace |
int |
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). |
java.util.List<org.apache.cassandra.thrift.KeySlice> |
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> |
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.ColumnOrSuperColumn> |
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 |
org.apache.cassandra.thrift.ColumnOrSuperColumn |
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 |
void |
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 |
login(org.apache.cassandra.thrift.AuthenticationRequest authRequest)
Authenticates with the cluster for operations on the specified keyspace using the specified AuthenticationRequest credentials |
java.util.Map<java.nio.ByteBuffer,java.lang.Integer> |
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.util.List<org.apache.cassandra.thrift.ColumnOrSuperColumn>> |
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 |
void |
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 |
set_keyspace(java.lang.String keySpace)
Set the keyspace to work on |
java.lang.String |
system_add_column_family(org.apache.cassandra.thrift.CfDef cfDef)
Adds a column family. |
java.lang.String |
system_add_keyspace(org.apache.cassandra.thrift.KsDef ksDef)
Creates a new keyspace and any column families defined with it. |
java.lang.String |
system_drop_column_family(java.lang.String columnFamily)
Drops a column family. |
java.lang.String |
system_drop_keyspace(java.lang.String keySpace)
Drops a keyspace. |
java.lang.String |
system_update_column_family(org.apache.cassandra.thrift.CfDef columnFamily)
Update the properties of a column family |
java.lang.String |
system_update_keyspace(org.apache.cassandra.thrift.KsDef keySpace)
Update the properties of a keyspace |
void |
truncate(java.lang.String columnFamily)
Remove all the rows from the given column family |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public CassandraWrapper() throws java.net.UnknownHostException, InternalBackEndException
java.net.UnknownHostException
InternalBackEndException
public CassandraWrapper(java.lang.String address, int port) throws InternalBackEndException
address
- the address to use for the connectionport
- the port to use for the connection
InternalBackEndException
Method Detail |
---|
public void login(org.apache.cassandra.thrift.AuthenticationRequest authRequest) throws InternalBackEndException
ICassandraWrapper
AuthenticationRequest
credentials
login
in interface ICassandraWrapper
InternalBackEndException
public void set_keyspace(java.lang.String keySpace) throws InternalBackEndException
ICassandraWrapper
set_keyspace
in interface ICassandraWrapper
keySpace
- the name of the keyspace
InternalBackEndException
public org.apache.cassandra.thrift.ColumnOrSuperColumn get(java.lang.String key, org.apache.cassandra.thrift.ColumnPath path, org.apache.cassandra.thrift.ConsistencyLevel level) throws IOBackEndException, InternalBackEndException
ICassandraWrapper
Column
or SuperColumn
at the given column path
get
in interface ICassandraWrapper
level
- the ConsistencyLevel to use
Column
or SuperColumn
at the given column path
InternalBackEndException
IOBackEndException
public java.util.List<org.apache.cassandra.thrift.ColumnOrSuperColumn> get_slice(java.lang.String key, org.apache.cassandra.thrift.ColumnParent parent, org.apache.cassandra.thrift.SlicePredicate predicate, org.apache.cassandra.thrift.ConsistencyLevel level) throws InternalBackEndException
ICassandraWrapper
get_slice
in interface ICassandraWrapper
parent
- either a ColumnFamily
or a ColumnFamily
/
SuperColum
pairpredicate
- the SlicePredicate
level
- the ConsistencyLevel
to use
InternalBackEndException
public java.util.Map<java.nio.ByteBuffer,java.util.List<org.apache.cassandra.thrift.ColumnOrSuperColumn>> 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) throws InternalBackEndException
ICassandraWrapper
multiget_slice
in interface ICassandraWrapper
keys
- the list of keyspredicate
- the SlicePredicate
level
- the ConsistencyLevel
to use
InternalBackEndException
public int get_count(java.lang.String key, org.apache.cassandra.thrift.ColumnParent parent, org.apache.cassandra.thrift.SlicePredicate predicate, org.apache.cassandra.thrift.ConsistencyLevel level) throws InternalBackEndException
ICassandraWrapper
get_count
in interface ICassandraWrapper
predicate
- the SlicePredicate
level
- the ConsistencyLevel
to use
InternalBackEndException
public java.util.Map<java.nio.ByteBuffer,java.lang.Integer> 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) throws InternalBackEndException
ICassandraWrapper
multiget_slice
and get_count
multiget_count
in interface ICassandraWrapper
predicate
- the SlicePredicate
level
- the ConsistencyLevel
to use
InternalBackEndException
public java.util.List<org.apache.cassandra.thrift.KeySlice> 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) throws InternalBackEndException
ICassandraWrapper
KeyRange
get_range_slices
in interface ICassandraWrapper
predicate
- the SlicePredicate
range
- the KeyRange
level
- the ConsistencyLevel
to use
InternalBackEndException
public java.util.List<org.apache.cassandra.thrift.KeySlice> 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) throws InternalBackEndException
ICassandraWrapper
IndexClause
instead of
KeyRange
. To use this method, the underlying ColumnFamily
of the ColumnParent
must have been configured with a
column_metadata attribute, specifying at least the name and index_type
attributes. See CfDef
and ColumnDef
for the list of
attributes.
get_indexed_slices
in interface ICassandraWrapper
clause
- the IndexClause
to usepredicate
- the SlicePredicate
level
- the ConsistencyLevel
to use
InternalBackEndException
public void insert(java.lang.String key, org.apache.cassandra.thrift.ColumnParent parent, org.apache.cassandra.thrift.Column column, org.apache.cassandra.thrift.ConsistencyLevel level) throws InternalBackEndException
ICassandraWrapper
Column
consisting of (name, value, timestamp) at the given
ColumnPath.column_family and optional ColumnPath.super_column. Note that a
SuperColumn
cannot directly contain binary values, it can only
contain sub-Columns. Only one sub-Column may be inserted at a time, as
well.
insert
in interface ICassandraWrapper
InternalBackEndException
public void 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) throws InternalBackEndException
ICassandraWrapper
Mutation
specifies either columns to insert or columns to delete
batch_mutate
in interface ICassandraWrapper
InternalBackEndException
public void 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) throws InternalBackEndException
InternalBackEndException
public void remove(java.lang.String key, org.apache.cassandra.thrift.ColumnPath path, long timeStamp, org.apache.cassandra.thrift.ConsistencyLevel level) throws InternalBackEndException
ICassandraWrapper
key
at the granularity
specified by the ColumnPath
path
, and the given timestamp.
remove
in interface ICassandraWrapper
level
- the ConsistencyLevel
to use
InternalBackEndException
public void truncate(java.lang.String columnFamily) throws InternalBackEndException
ICassandraWrapper
truncate
in interface ICassandraWrapper
InternalBackEndException
public java.lang.String describe_cluster_name() throws InternalBackEndException
describe_cluster_name
in interface ICassandraWrapper
InternalBackEndException
public org.apache.cassandra.thrift.KsDef describe_keyspace(java.lang.String keySpace) throws InternalBackEndException, IOBackEndException
describe_keyspace
in interface ICassandraWrapper
InternalBackEndException
IOBackEndException
public java.util.List<org.apache.cassandra.thrift.KsDef> describe_keyspaces() throws InternalBackEndException
describe_keyspaces
in interface ICassandraWrapper
InternalBackEndException
public java.lang.String describe_partitioner() throws InternalBackEndException
describe_partitioner
in interface ICassandraWrapper
InternalBackEndException
public java.util.List<org.apache.cassandra.thrift.TokenRange> describe_ring(java.lang.String keySpace) throws InternalBackEndException
ICassandraWrapper
TokenRange
instead of a map from range to list of end points
describe_ring
in interface ICassandraWrapper
InternalBackEndException
public java.lang.String describe_snitch() throws InternalBackEndException
describe_snitch
in interface ICassandraWrapper
InternalBackEndException
public java.lang.String describe_version() throws InternalBackEndException
describe_version
in interface ICassandraWrapper
InternalBackEndException
public java.lang.String system_add_column_family(org.apache.cassandra.thrift.CfDef cfDef) throws InternalBackEndException
ICassandraWrapper
system_add_column_family
in interface ICassandraWrapper
InternalBackEndException
public java.lang.String system_drop_column_family(java.lang.String columnFamily) throws InternalBackEndException
ICassandraWrapper
system_drop_column_family
in interface ICassandraWrapper
InternalBackEndException
public java.lang.String system_add_keyspace(org.apache.cassandra.thrift.KsDef ksDef) throws InternalBackEndException
ICassandraWrapper
system_add_keyspace
in interface ICassandraWrapper
ksDef
- the keyspace definition
InternalBackEndException
public java.lang.String system_drop_keyspace(java.lang.String keySpace) throws InternalBackEndException
ICassandraWrapper
system_drop_keyspace
in interface ICassandraWrapper
InternalBackEndException
public java.lang.String system_update_column_family(org.apache.cassandra.thrift.CfDef columnFamily) throws InternalBackEndException
ICassandraWrapper
system_update_column_family
in interface ICassandraWrapper
InternalBackEndException
public java.lang.String system_update_keyspace(org.apache.cassandra.thrift.KsDef keySpace) throws InternalBackEndException
ICassandraWrapper
system_update_keyspace
in interface ICassandraWrapper
InternalBackEndException
public int get_cf_id(java.lang.String keySpaceName, java.lang.String columnFamilyName) throws InternalBackEndException, IOBackEndException
keySpaceName
- the keyspace where the column family is locatedcolumnFamilyName
- the column family to search
InternalBackEndException
IOBackEndException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |