|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface KeyspaceService
The keyspace is a high level handle to all read/write operations to cassandra. A Keyspace object is NOT THREAD SAFE. Use one keyspace per thread please!
Field Summary | |
---|---|
static String |
CF_TYPE
|
static String |
CF_TYPE_STANDARD
|
static String |
CF_TYPE_SUPER
|
Method Summary | |
---|---|
void |
addCounter(ByteBuffer key,
org.apache.cassandra.thrift.ColumnParent columnParent,
org.apache.cassandra.thrift.CounterColumn counterColumn)
Add a counter with CL.ONE |
void |
addCounter(String key,
org.apache.cassandra.thrift.ColumnParent columnParent,
org.apache.cassandra.thrift.CounterColumn counterColumn)
Add a counter with CL.ONE |
void |
batchMutate(BatchMutation batchMutation)
Call batch mutate with the BatchMutation object which encapsulates some of the complexity of the batch_mutate API signature |
void |
batchMutate(Map<ByteBuffer,Map<String,List<org.apache.cassandra.thrift.Mutation>>> mutationMap)
Call batch mutate with the assembled mutationMap. |
CassandraHost |
getCassandraHost()
|
org.apache.cassandra.thrift.Column |
getColumn(ByteBuffer key,
org.apache.cassandra.thrift.ColumnPath columnPath)
Get the Column at the given columnPath. |
org.apache.cassandra.thrift.Column |
getColumn(String key,
org.apache.cassandra.thrift.ColumnPath columnPath)
|
HConsistencyLevel |
getConsistencyLevel(OperationType operationType)
|
int |
getCount(ByteBuffer key,
org.apache.cassandra.thrift.ColumnParent columnParent,
org.apache.cassandra.thrift.SlicePredicate predicate)
Counts the columns present in columnParent. |
org.apache.cassandra.thrift.CounterColumn |
getCounter(ByteBuffer key,
org.apache.cassandra.thrift.ColumnPath columnPath)
Get the Counter at the given columnPath. |
org.apache.cassandra.thrift.CounterColumn |
getCounter(String key,
org.apache.cassandra.thrift.ColumnPath columnPath)
|
List<org.apache.cassandra.thrift.CounterColumn> |
getCounterSlice(ByteBuffer key,
org.apache.cassandra.thrift.ColumnParent columnParent,
org.apache.cassandra.thrift.SlicePredicate predicate)
Get the group of counter columns contained by columnParent. |
List<org.apache.cassandra.thrift.CounterColumn> |
getCounterSlice(String key,
org.apache.cassandra.thrift.ColumnParent columnParent,
org.apache.cassandra.thrift.SlicePredicate predicate)
|
List<org.apache.cassandra.thrift.CounterSuperColumn> |
getCounterSuperSlice(ByteBuffer key,
org.apache.cassandra.thrift.ColumnParent columnParent,
org.apache.cassandra.thrift.SlicePredicate predicate)
Get the group of superColumn contained by columnParent. |
List<org.apache.cassandra.thrift.CounterSuperColumn> |
getCounterSuperSlice(String key,
org.apache.cassandra.thrift.ColumnParent columnParent,
org.apache.cassandra.thrift.SlicePredicate predicate)
|
Map<ByteBuffer,List<org.apache.cassandra.thrift.Column>> |
getIndexedSlices(org.apache.cassandra.thrift.ColumnParent columnParent,
org.apache.cassandra.thrift.IndexClause indexClause,
org.apache.cassandra.thrift.SlicePredicate predicate)
returns a subset of columns for a range of keys. |
String |
getName()
|
Map<ByteBuffer,List<org.apache.cassandra.thrift.CounterColumn>> |
getRangeCounterSlices(org.apache.cassandra.thrift.ColumnParent columnParent,
org.apache.cassandra.thrift.SlicePredicate predicate,
org.apache.cassandra.thrift.KeyRange keyRange)
returns a subset of counter columns for a range of keys |
Map<ByteBuffer,List<org.apache.cassandra.thrift.Column>> |
getRangeSlices(org.apache.cassandra.thrift.ColumnParent columnParent,
org.apache.cassandra.thrift.SlicePredicate predicate,
org.apache.cassandra.thrift.KeyRange keyRange)
returns a subset of columns for a range of keys. |
List<org.apache.cassandra.thrift.Column> |
getSlice(ByteBuffer key,
org.apache.cassandra.thrift.ColumnParent columnParent,
org.apache.cassandra.thrift.SlicePredicate predicate)
Get the group of columns contained by columnParent. |
List<org.apache.cassandra.thrift.Column> |
getSlice(String key,
org.apache.cassandra.thrift.ColumnParent columnParent,
org.apache.cassandra.thrift.SlicePredicate predicate)
|
org.apache.cassandra.thrift.SuperColumn |
getSuperColumn(ByteBuffer key,
org.apache.cassandra.thrift.ColumnPath columnPath)
Get the SuperColumn at the given columnPath. |
org.apache.cassandra.thrift.SuperColumn |
getSuperColumn(ByteBuffer key,
org.apache.cassandra.thrift.ColumnPath columnPath,
boolean reversed,
int size)
Get the SuperColumn at the given columnPath. |
org.apache.cassandra.thrift.SuperColumn |
getSuperColumn(String key,
org.apache.cassandra.thrift.ColumnPath columnPath)
|
Map<ByteBuffer,List<org.apache.cassandra.thrift.CounterSuperColumn>> |
getSuperRangeCounterSlices(org.apache.cassandra.thrift.ColumnParent columnParent,
org.apache.cassandra.thrift.SlicePredicate predicate,
org.apache.cassandra.thrift.KeyRange keyRange)
returns a subset of counter super columns for a range of keys |
Map<ByteBuffer,List<org.apache.cassandra.thrift.SuperColumn>> |
getSuperRangeSlices(org.apache.cassandra.thrift.ColumnParent columnParent,
org.apache.cassandra.thrift.SlicePredicate predicate,
org.apache.cassandra.thrift.KeyRange keyRange)
returns a subset of super columns for a range of keys. |
List<org.apache.cassandra.thrift.SuperColumn> |
getSuperSlice(ByteBuffer key,
org.apache.cassandra.thrift.ColumnParent columnParent,
org.apache.cassandra.thrift.SlicePredicate predicate)
Get the group of superColumn contained by columnParent. |
List<org.apache.cassandra.thrift.SuperColumn> |
getSuperSlice(String key,
org.apache.cassandra.thrift.ColumnParent columnParent,
org.apache.cassandra.thrift.SlicePredicate predicate)
|
void |
insert(ByteBuffer key,
org.apache.cassandra.thrift.ColumnParent columnParent,
org.apache.cassandra.thrift.Column column)
Inserts a column. |
void |
insert(String key,
org.apache.cassandra.thrift.ColumnPath columnPath,
ByteBuffer value)
|
void |
insert(String key,
org.apache.cassandra.thrift.ColumnPath columnPath,
ByteBuffer value,
long timestamp)
|
Map<ByteBuffer,Integer> |
multigetCount(List<ByteBuffer> keys,
org.apache.cassandra.thrift.ColumnParent columnParent,
org.apache.cassandra.thrift.SlicePredicate slicePredicate)
Returns a map of key to column count |
Map<ByteBuffer,List<org.apache.cassandra.thrift.CounterColumn>> |
multigetCounterSlice(List<ByteBuffer> keys,
org.apache.cassandra.thrift.ColumnParent columnParent,
org.apache.cassandra.thrift.SlicePredicate predicate)
Performs a get_slice for columnParent and predicate for the given keys in parallel. |
Map<ByteBuffer,List<org.apache.cassandra.thrift.CounterSuperColumn>> |
multigetCounterSuperSlice(List<ByteBuffer> keys,
org.apache.cassandra.thrift.ColumnParent columnParent,
org.apache.cassandra.thrift.SlicePredicate predicate)
Performs a get_slice for a superColumn columnParent and predicate for the given keys in parallel. |
Map<ByteBuffer,List<org.apache.cassandra.thrift.Column>> |
multigetSlice(List<ByteBuffer> keys,
org.apache.cassandra.thrift.ColumnParent columnParent,
org.apache.cassandra.thrift.SlicePredicate predicate)
Performs a get_slice for columnParent and predicate for the given keys in parallel. |
Map<ByteBuffer,org.apache.cassandra.thrift.SuperColumn> |
multigetSuperColumn(List<ByteBuffer> keys,
org.apache.cassandra.thrift.ColumnPath columnPath)
Performs a get for columnPath in parallel on the given list of keys. |
Map<ByteBuffer,org.apache.cassandra.thrift.SuperColumn> |
multigetSuperColumn(List<ByteBuffer> keys,
org.apache.cassandra.thrift.ColumnPath columnPath,
boolean reversed,
int size)
Perform a get for columnPath in parallel on the given list of keys. |
Map<ByteBuffer,List<org.apache.cassandra.thrift.SuperColumn>> |
multigetSuperSlice(List<ByteBuffer> keys,
org.apache.cassandra.thrift.ColumnParent columnParent,
org.apache.cassandra.thrift.SlicePredicate predicate)
Performs a get_slice for a superColumn columnParent and predicate for the given keys in parallel. |
void |
remove(ByteBuffer key,
org.apache.cassandra.thrift.ColumnPath columnPath)
|
void |
remove(ByteBuffer key,
org.apache.cassandra.thrift.ColumnPath columnPath,
long timestamp)
Same as two argument version, but the caller must specify their own clock |
void |
remove(String key,
org.apache.cassandra.thrift.ColumnPath columnPath)
|
void |
remove(String key,
org.apache.cassandra.thrift.ColumnPath columnPath,
long timestamp)
|
void |
removeCounter(ByteBuffer key,
org.apache.cassandra.thrift.ColumnPath columnPath)
|
void |
removeCounter(String key,
org.apache.cassandra.thrift.ColumnPath columnPath)
|
Field Detail |
---|
static final String CF_TYPE
static final String CF_TYPE_STANDARD
static final String CF_TYPE_SUPER
Method Detail |
---|
org.apache.cassandra.thrift.Column getColumn(ByteBuffer key, org.apache.cassandra.thrift.ColumnPath columnPath) throws HectorException
HNotFoundException
- if no value exists for the column
HectorException
org.apache.cassandra.thrift.Column getColumn(String key, org.apache.cassandra.thrift.ColumnPath columnPath) throws HectorException
HectorException
org.apache.cassandra.thrift.CounterColumn getCounter(ByteBuffer key, org.apache.cassandra.thrift.ColumnPath columnPath) throws HectorException
HNotFoundException
- if no value exists for the counter
HectorException
org.apache.cassandra.thrift.CounterColumn getCounter(String key, org.apache.cassandra.thrift.ColumnPath columnPath) throws HectorException
HectorException
org.apache.cassandra.thrift.SuperColumn getSuperColumn(ByteBuffer key, org.apache.cassandra.thrift.ColumnPath columnPath) throws HectorException
HNotFoundException
- when a supercolumn is not found
HectorException
org.apache.cassandra.thrift.SuperColumn getSuperColumn(String key, org.apache.cassandra.thrift.ColumnPath columnPath) throws HectorException
HectorException
org.apache.cassandra.thrift.SuperColumn getSuperColumn(ByteBuffer key, org.apache.cassandra.thrift.ColumnPath columnPath, boolean reversed, int size) throws HectorException
reversed
- the result Column sortsize
- the result column size
HNotFoundException
- when a supercolumn is not found
HectorException
List<org.apache.cassandra.thrift.Column> getSlice(ByteBuffer key, org.apache.cassandra.thrift.ColumnParent columnParent, org.apache.cassandra.thrift.SlicePredicate predicate) throws HectorException
HectorException
List<org.apache.cassandra.thrift.Column> getSlice(String key, org.apache.cassandra.thrift.ColumnParent columnParent, org.apache.cassandra.thrift.SlicePredicate predicate) throws HectorException
HectorException
List<org.apache.cassandra.thrift.CounterColumn> getCounterSlice(ByteBuffer key, org.apache.cassandra.thrift.ColumnParent columnParent, org.apache.cassandra.thrift.SlicePredicate predicate) throws HectorException
HectorException
List<org.apache.cassandra.thrift.CounterColumn> getCounterSlice(String key, org.apache.cassandra.thrift.ColumnParent columnParent, org.apache.cassandra.thrift.SlicePredicate predicate) throws HectorException
HectorException
List<org.apache.cassandra.thrift.SuperColumn> getSuperSlice(ByteBuffer key, org.apache.cassandra.thrift.ColumnParent columnParent, org.apache.cassandra.thrift.SlicePredicate predicate) throws HectorException
HectorException
List<org.apache.cassandra.thrift.SuperColumn> getSuperSlice(String key, org.apache.cassandra.thrift.ColumnParent columnParent, org.apache.cassandra.thrift.SlicePredicate predicate) throws HectorException
HectorException
List<org.apache.cassandra.thrift.CounterSuperColumn> getCounterSuperSlice(ByteBuffer key, org.apache.cassandra.thrift.ColumnParent columnParent, org.apache.cassandra.thrift.SlicePredicate predicate) throws HectorException
HectorException
List<org.apache.cassandra.thrift.CounterSuperColumn> getCounterSuperSlice(String key, org.apache.cassandra.thrift.ColumnParent columnParent, org.apache.cassandra.thrift.SlicePredicate predicate) throws HectorException
HectorException
Map<ByteBuffer,org.apache.cassandra.thrift.SuperColumn> multigetSuperColumn(List<ByteBuffer> keys, org.apache.cassandra.thrift.ColumnPath columnPath) throws HectorException
HectorException
Map<ByteBuffer,org.apache.cassandra.thrift.SuperColumn> multigetSuperColumn(List<ByteBuffer> keys, org.apache.cassandra.thrift.ColumnPath columnPath, boolean reversed, int size) throws HectorException
HectorException
Map<ByteBuffer,List<org.apache.cassandra.thrift.Column>> multigetSlice(List<ByteBuffer> keys, org.apache.cassandra.thrift.ColumnParent columnParent, org.apache.cassandra.thrift.SlicePredicate predicate) throws HectorException
HectorException
Map<ByteBuffer,List<org.apache.cassandra.thrift.CounterColumn>> multigetCounterSlice(List<ByteBuffer> keys, org.apache.cassandra.thrift.ColumnParent columnParent, org.apache.cassandra.thrift.SlicePredicate predicate) throws HectorException
HectorException
Map<ByteBuffer,List<org.apache.cassandra.thrift.SuperColumn>> multigetSuperSlice(List<ByteBuffer> keys, org.apache.cassandra.thrift.ColumnParent columnParent, org.apache.cassandra.thrift.SlicePredicate predicate) throws HectorException
HectorException
Map<ByteBuffer,List<org.apache.cassandra.thrift.CounterSuperColumn>> multigetCounterSuperSlice(List<ByteBuffer> keys, org.apache.cassandra.thrift.ColumnParent columnParent, org.apache.cassandra.thrift.SlicePredicate predicate) throws HectorException
HectorException
void insert(ByteBuffer key, org.apache.cassandra.thrift.ColumnParent columnParent, org.apache.cassandra.thrift.Column column) throws HectorException
HectorException
void insert(String key, org.apache.cassandra.thrift.ColumnPath columnPath, ByteBuffer value) throws HectorException
HectorException
void insert(String key, org.apache.cassandra.thrift.ColumnPath columnPath, ByteBuffer value, long timestamp) throws HectorException
HectorException
void addCounter(ByteBuffer key, org.apache.cassandra.thrift.ColumnParent columnParent, org.apache.cassandra.thrift.CounterColumn counterColumn) throws HectorException
HectorException
void addCounter(String key, org.apache.cassandra.thrift.ColumnParent columnParent, org.apache.cassandra.thrift.CounterColumn counterColumn) throws HectorException
HectorException
void batchMutate(Map<ByteBuffer,Map<String,List<org.apache.cassandra.thrift.Mutation>>> mutationMap) throws HectorException
HectorException
void batchMutate(BatchMutation batchMutation) throws HectorException
HectorException
void remove(ByteBuffer key, org.apache.cassandra.thrift.ColumnPath columnPath)
void remove(ByteBuffer key, org.apache.cassandra.thrift.ColumnPath columnPath, long timestamp) throws HectorException
HectorException
void remove(String key, org.apache.cassandra.thrift.ColumnPath columnPath) throws HectorException
HectorException
void remove(String key, org.apache.cassandra.thrift.ColumnPath columnPath, long timestamp) throws HectorException
HectorException
void removeCounter(ByteBuffer key, org.apache.cassandra.thrift.ColumnPath columnPath) throws HectorException
HectorException
void removeCounter(String key, org.apache.cassandra.thrift.ColumnPath columnPath) throws HectorException
HectorException
int getCount(ByteBuffer key, org.apache.cassandra.thrift.ColumnParent columnParent, org.apache.cassandra.thrift.SlicePredicate predicate) throws HectorException
HectorException
Map<ByteBuffer,List<org.apache.cassandra.thrift.Column>> getRangeSlices(org.apache.cassandra.thrift.ColumnParent columnParent, org.apache.cassandra.thrift.SlicePredicate predicate, org.apache.cassandra.thrift.KeyRange keyRange) throws HectorException
HectorException
Map<ByteBuffer,List<org.apache.cassandra.thrift.CounterColumn>> getRangeCounterSlices(org.apache.cassandra.thrift.ColumnParent columnParent, org.apache.cassandra.thrift.SlicePredicate predicate, org.apache.cassandra.thrift.KeyRange keyRange) throws HectorException
HectorException
Map<ByteBuffer,List<org.apache.cassandra.thrift.SuperColumn>> getSuperRangeSlices(org.apache.cassandra.thrift.ColumnParent columnParent, org.apache.cassandra.thrift.SlicePredicate predicate, org.apache.cassandra.thrift.KeyRange keyRange) throws HectorException
HectorException
Map<ByteBuffer,List<org.apache.cassandra.thrift.CounterSuperColumn>> getSuperRangeCounterSlices(org.apache.cassandra.thrift.ColumnParent columnParent, org.apache.cassandra.thrift.SlicePredicate predicate, org.apache.cassandra.thrift.KeyRange keyRange)
Map<ByteBuffer,List<org.apache.cassandra.thrift.Column>> getIndexedSlices(org.apache.cassandra.thrift.ColumnParent columnParent, org.apache.cassandra.thrift.IndexClause indexClause, org.apache.cassandra.thrift.SlicePredicate predicate) throws HectorException
HectorException
Map<ByteBuffer,Integer> multigetCount(List<ByteBuffer> keys, org.apache.cassandra.thrift.ColumnParent columnParent, org.apache.cassandra.thrift.SlicePredicate slicePredicate) throws HectorException
HectorException
HConsistencyLevel getConsistencyLevel(OperationType operationType)
String getName()
CassandraHost getCassandraHost()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |