|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface ICassandraWrapper
CassandraWrapper API - for Cassandra starting at version 0.7
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 |
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_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 |
Method Detail |
---|
void login(org.apache.cassandra.thrift.AuthenticationRequest authRequest) throws InternalBackEndException
AuthenticationRequest
credentials
authRequest
-
InternalBackEndException
void set_keyspace(java.lang.String keySpace) throws InternalBackEndException
keySpace
- the name of the keyspace
InternalBackEndException
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
Column
or SuperColumn
at the given column path
key
- path
- level
- the ConsistencyLevel to use
Column
or SuperColumn
at the given column path
IOBackendException
- if no value is present
InternalBackEndException
IOBackEndException
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, IOBackEndException
key
- parent
- either a ColumnFamily
or a ColumnFamily
/
SuperColum
pairpredicate
- the SlicePredicate
level
- the ConsistencyLevel
to use
InternalBackEndException
IOBackEndException
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
keys
- the list of keysparent
- predicate
- the SlicePredicate
level
- the ConsistencyLevel
to use
InternalBackEndException
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
key
- parent
- predicate
- the SlicePredicate
level
- the ConsistencyLevel
to use
InternalBackEndException
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
multiget_slice
and get_count
keys
- parent
- predicate
- the SlicePredicate
level
- the ConsistencyLevel
to use
InternalBackEndException
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
KeyRange
parent
- predicate
- the SlicePredicate
range
- the KeyRange
level
- the ConsistencyLevel
to use
InternalBackEndException
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
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.
parent
- clause
- the IndexClause
to usepredicate
- the SlicePredicate
level
- the ConsistencyLevel
to use
InternalBackEndException
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
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.
key
- parent
- column
- level
-
InternalBackEndException
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
Mutation
specifies either columns to insert or columns to delete
mutationMap
- level
-
InternalBackEndException
void remove(java.lang.String key, org.apache.cassandra.thrift.ColumnPath path, long timeStamp, org.apache.cassandra.thrift.ConsistencyLevel level) throws InternalBackEndException
key
at the granularity
specified by the ColumnPath
path
, and the given timestamp.
key
- path
- timeStamp
- level
- the ConsistencyLevel
to use
InternalBackEndException
void truncate(java.lang.String columnFamily) throws InternalBackEndException
columnFamily
-
InternalBackEndException
java.lang.String describe_cluster_name() throws InternalBackEndException
InternalBackEndException
org.apache.cassandra.thrift.KsDef describe_keyspace(java.lang.String keySpace) throws InternalBackEndException, IOBackEndException
keySpace
-
InternalBackEndException
IOBackEndException
java.util.List<org.apache.cassandra.thrift.KsDef> describe_keyspaces() throws InternalBackEndException
InternalBackEndException
java.lang.String describe_partitioner() throws InternalBackEndException
InternalBackEndException
java.util.List<org.apache.cassandra.thrift.TokenRange> describe_ring(java.lang.String keySpace) throws InternalBackEndException
TokenRange
instead of a map from range to list of end points
keySpace
-
InternalBackEndException
java.lang.String describe_snitch() throws InternalBackEndException
InternalBackEndException
java.lang.String describe_version() throws InternalBackEndException
InternalBackEndException
java.lang.String system_add_column_family(org.apache.cassandra.thrift.CfDef cfDef) throws InternalBackEndException
cfDef
-
InternalBackEndException
java.lang.String system_drop_column_family(java.lang.String columnFamily) throws InternalBackEndException
columnFamily
-
InternalBackEndException
java.lang.String system_add_keyspace(org.apache.cassandra.thrift.KsDef ksDef) throws InternalBackEndException
ksDef
- the keyspace definition
InternalBackEndException
java.lang.String system_drop_keyspace(java.lang.String keySpace) throws InternalBackEndException
keySpace
-
InternalBackEndException
java.lang.String system_update_column_family(org.apache.cassandra.thrift.CfDef columnFamily) throws InternalBackEndException
columnFamily
-
InternalBackEndException
java.lang.String system_update_keyspace(org.apache.cassandra.thrift.KsDef keySpace) throws InternalBackEndException
keySpace
-
InternalBackEndException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |