me.prettyprint.cassandra.service
Class VirtualKeyspaceCassandraClient
java.lang.Object
org.apache.cassandra.thrift.Cassandra.Client
me.prettyprint.cassandra.model.thrift.AbstractThriftClientWrapper
me.prettyprint.cassandra.service.VirtualKeyspaceCassandraClient
- All Implemented Interfaces:
- org.apache.cassandra.thrift.Cassandra.Iface, org.apache.thrift.TServiceClient
public class VirtualKeyspaceCassandraClient
- extends AbstractThriftClientWrapper
Nested classes/interfaces inherited from class org.apache.cassandra.thrift.Cassandra.Client |
org.apache.cassandra.thrift.Cassandra.Client.Factory |
Fields inherited from class org.apache.cassandra.thrift.Cassandra.Client |
iprot_, oprot_, seqid_ |
Method Summary |
void |
add(ByteBuffer key,
org.apache.cassandra.thrift.ColumnParent column_parent,
org.apache.cassandra.thrift.CounterColumn column,
org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
|
void |
batch_mutate(Map<ByteBuffer,Map<String,List<org.apache.cassandra.thrift.Mutation>>> mutation_map,
org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
|
int |
get_count(ByteBuffer key,
org.apache.cassandra.thrift.ColumnParent column_parent,
org.apache.cassandra.thrift.SlicePredicate predicate,
org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
|
List<org.apache.cassandra.thrift.KeySlice> |
get_indexed_slices(org.apache.cassandra.thrift.ColumnParent column_parent,
org.apache.cassandra.thrift.IndexClause index_clause,
org.apache.cassandra.thrift.SlicePredicate column_predicate,
org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
|
List<org.apache.cassandra.thrift.KeySlice> |
get_range_slices(org.apache.cassandra.thrift.ColumnParent column_parent,
org.apache.cassandra.thrift.SlicePredicate predicate,
org.apache.cassandra.thrift.KeyRange range,
org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
|
List<org.apache.cassandra.thrift.ColumnOrSuperColumn> |
get_slice(ByteBuffer key,
org.apache.cassandra.thrift.ColumnParent column_parent,
org.apache.cassandra.thrift.SlicePredicate predicate,
org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
|
org.apache.cassandra.thrift.ColumnOrSuperColumn |
get(ByteBuffer key,
org.apache.cassandra.thrift.ColumnPath column_path,
org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
|
void |
insert(ByteBuffer key,
org.apache.cassandra.thrift.ColumnParent column_parent,
org.apache.cassandra.thrift.Column column,
org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
|
Map<ByteBuffer,Integer> |
multiget_count(List<ByteBuffer> keys,
org.apache.cassandra.thrift.ColumnParent column_parent,
org.apache.cassandra.thrift.SlicePredicate predicate,
org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
|
Map<ByteBuffer,List<org.apache.cassandra.thrift.ColumnOrSuperColumn>> |
multiget_slice(List<ByteBuffer> keys,
org.apache.cassandra.thrift.ColumnParent column_parent,
org.apache.cassandra.thrift.SlicePredicate predicate,
org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
|
org.apache.cassandra.thrift.KeyRange |
prefixKeyRange(org.apache.cassandra.thrift.KeyRange unprefixed)
|
org.apache.cassandra.thrift.KeySlice |
prefixKeySlice(org.apache.cassandra.thrift.KeySlice unprefixed)
|
List<org.apache.cassandra.thrift.KeySlice> |
prefixKeySlice(List<org.apache.cassandra.thrift.KeySlice> unprefixed)
|
void |
remove_counter(ByteBuffer key,
org.apache.cassandra.thrift.ColumnPath path,
org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
|
void |
remove(ByteBuffer key,
org.apache.cassandra.thrift.ColumnPath column_path,
long timestamp,
org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
|
org.apache.cassandra.thrift.KeyRange |
unprefixKeyRange(org.apache.cassandra.thrift.KeyRange prefixed)
|
org.apache.cassandra.thrift.KeySlice |
unprefixKeySlice(org.apache.cassandra.thrift.KeySlice prefixed)
|
List<org.apache.cassandra.thrift.KeySlice> |
unprefixKeySlice(List<org.apache.cassandra.thrift.KeySlice> prefixed)
|
Methods inherited from class me.prettyprint.cassandra.model.thrift.AbstractThriftClientWrapper |
describe_cluster_name, describe_keyspace, describe_keyspaces, describe_partitioner, describe_ring, describe_schema_versions, describe_snitch, describe_splits, describe_version, execute_cql_query, getInputProtocol, getOutputProtocol, login, recv_add, recv_batch_mutate, recv_describe_cluster_name, recv_describe_keyspace, recv_describe_keyspaces, recv_describe_partitioner, recv_describe_ring, recv_describe_schema_versions, recv_describe_snitch, recv_describe_splits, recv_describe_version, recv_execute_cql_query, recv_get_count, recv_get_indexed_slices, recv_get_range_slices, recv_get_slice, recv_get, recv_insert, recv_login, recv_multiget_count, recv_multiget_slice, recv_remove_counter, recv_remove, recv_set_keyspace, recv_system_add_column_family, recv_system_add_keyspace, recv_system_drop_column_family, recv_system_drop_keyspace, recv_system_update_column_family, recv_system_update_keyspace, recv_truncate, send_add, send_batch_mutate, send_describe_cluster_name, send_describe_keyspace, send_describe_keyspaces, send_describe_partitioner, send_describe_ring, send_describe_schema_versions, send_describe_snitch, send_describe_splits, send_describe_version, send_execute_cql_query, send_get_count, send_get_indexed_slices, send_get_range_slices, send_get_slice, send_get, send_insert, send_login, send_multiget_count, send_multiget_slice, send_remove_counter, send_remove, send_set_keyspace, send_system_add_column_family, send_system_add_keyspace, send_system_drop_column_family, send_system_drop_keyspace, send_system_update_column_family, send_system_update_keyspace, send_truncate, set_keyspace, system_add_column_family, system_add_keyspace, system_drop_column_family, system_drop_keyspace, system_update_column_family, system_update_keyspace, truncate |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
VirtualKeyspaceCassandraClient
public VirtualKeyspaceCassandraClient(org.apache.cassandra.thrift.Cassandra.Client client,
ByteBuffer prefixBytes)
prefixKeyRange
public org.apache.cassandra.thrift.KeyRange prefixKeyRange(org.apache.cassandra.thrift.KeyRange unprefixed)
unprefixKeyRange
public org.apache.cassandra.thrift.KeyRange unprefixKeyRange(org.apache.cassandra.thrift.KeyRange prefixed)
prefixKeySlice
public org.apache.cassandra.thrift.KeySlice prefixKeySlice(org.apache.cassandra.thrift.KeySlice unprefixed)
unprefixKeySlice
public org.apache.cassandra.thrift.KeySlice unprefixKeySlice(org.apache.cassandra.thrift.KeySlice prefixed)
prefixKeySlice
public List<org.apache.cassandra.thrift.KeySlice> prefixKeySlice(List<org.apache.cassandra.thrift.KeySlice> unprefixed)
unprefixKeySlice
public List<org.apache.cassandra.thrift.KeySlice> unprefixKeySlice(List<org.apache.cassandra.thrift.KeySlice> prefixed)
add
public void add(ByteBuffer key,
org.apache.cassandra.thrift.ColumnParent column_parent,
org.apache.cassandra.thrift.CounterColumn column,
org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
throws org.apache.cassandra.thrift.InvalidRequestException,
org.apache.cassandra.thrift.UnavailableException,
org.apache.cassandra.thrift.TimedOutException,
org.apache.thrift.TException
- Specified by:
add
in interface org.apache.cassandra.thrift.Cassandra.Iface
- Overrides:
add
in class AbstractThriftClientWrapper
- Throws:
org.apache.cassandra.thrift.InvalidRequestException
org.apache.cassandra.thrift.UnavailableException
org.apache.cassandra.thrift.TimedOutException
org.apache.thrift.TException
batch_mutate
public void batch_mutate(Map<ByteBuffer,Map<String,List<org.apache.cassandra.thrift.Mutation>>> mutation_map,
org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
throws org.apache.cassandra.thrift.InvalidRequestException,
org.apache.cassandra.thrift.UnavailableException,
org.apache.cassandra.thrift.TimedOutException,
org.apache.thrift.TException
- Specified by:
batch_mutate
in interface org.apache.cassandra.thrift.Cassandra.Iface
- Overrides:
batch_mutate
in class AbstractThriftClientWrapper
- Throws:
org.apache.cassandra.thrift.InvalidRequestException
org.apache.cassandra.thrift.UnavailableException
org.apache.cassandra.thrift.TimedOutException
org.apache.thrift.TException
get
public org.apache.cassandra.thrift.ColumnOrSuperColumn get(ByteBuffer key,
org.apache.cassandra.thrift.ColumnPath column_path,
org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
throws org.apache.cassandra.thrift.InvalidRequestException,
org.apache.cassandra.thrift.NotFoundException,
org.apache.cassandra.thrift.UnavailableException,
org.apache.cassandra.thrift.TimedOutException,
org.apache.thrift.TException
- Specified by:
get
in interface org.apache.cassandra.thrift.Cassandra.Iface
- Overrides:
get
in class AbstractThriftClientWrapper
- Throws:
org.apache.cassandra.thrift.InvalidRequestException
org.apache.cassandra.thrift.NotFoundException
org.apache.cassandra.thrift.UnavailableException
org.apache.cassandra.thrift.TimedOutException
org.apache.thrift.TException
get_count
public int get_count(ByteBuffer key,
org.apache.cassandra.thrift.ColumnParent column_parent,
org.apache.cassandra.thrift.SlicePredicate predicate,
org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
throws org.apache.cassandra.thrift.InvalidRequestException,
org.apache.cassandra.thrift.UnavailableException,
org.apache.cassandra.thrift.TimedOutException,
org.apache.thrift.TException
- Specified by:
get_count
in interface org.apache.cassandra.thrift.Cassandra.Iface
- Overrides:
get_count
in class AbstractThriftClientWrapper
- Throws:
org.apache.cassandra.thrift.InvalidRequestException
org.apache.cassandra.thrift.UnavailableException
org.apache.cassandra.thrift.TimedOutException
org.apache.thrift.TException
get_indexed_slices
public List<org.apache.cassandra.thrift.KeySlice> get_indexed_slices(org.apache.cassandra.thrift.ColumnParent column_parent,
org.apache.cassandra.thrift.IndexClause index_clause,
org.apache.cassandra.thrift.SlicePredicate column_predicate,
org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
throws org.apache.cassandra.thrift.InvalidRequestException,
org.apache.cassandra.thrift.UnavailableException,
org.apache.cassandra.thrift.TimedOutException,
org.apache.thrift.TException
- Specified by:
get_indexed_slices
in interface org.apache.cassandra.thrift.Cassandra.Iface
- Overrides:
get_indexed_slices
in class AbstractThriftClientWrapper
- Throws:
org.apache.cassandra.thrift.InvalidRequestException
org.apache.cassandra.thrift.UnavailableException
org.apache.cassandra.thrift.TimedOutException
org.apache.thrift.TException
get_range_slices
public List<org.apache.cassandra.thrift.KeySlice> get_range_slices(org.apache.cassandra.thrift.ColumnParent column_parent,
org.apache.cassandra.thrift.SlicePredicate predicate,
org.apache.cassandra.thrift.KeyRange range,
org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
throws org.apache.cassandra.thrift.InvalidRequestException,
org.apache.cassandra.thrift.UnavailableException,
org.apache.cassandra.thrift.TimedOutException,
org.apache.thrift.TException
- Specified by:
get_range_slices
in interface org.apache.cassandra.thrift.Cassandra.Iface
- Overrides:
get_range_slices
in class AbstractThriftClientWrapper
- Throws:
org.apache.cassandra.thrift.InvalidRequestException
org.apache.cassandra.thrift.UnavailableException
org.apache.cassandra.thrift.TimedOutException
org.apache.thrift.TException
get_slice
public List<org.apache.cassandra.thrift.ColumnOrSuperColumn> get_slice(ByteBuffer key,
org.apache.cassandra.thrift.ColumnParent column_parent,
org.apache.cassandra.thrift.SlicePredicate predicate,
org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
throws org.apache.cassandra.thrift.InvalidRequestException,
org.apache.cassandra.thrift.UnavailableException,
org.apache.cassandra.thrift.TimedOutException,
org.apache.thrift.TException
- Specified by:
get_slice
in interface org.apache.cassandra.thrift.Cassandra.Iface
- Overrides:
get_slice
in class AbstractThriftClientWrapper
- Throws:
org.apache.cassandra.thrift.InvalidRequestException
org.apache.cassandra.thrift.UnavailableException
org.apache.cassandra.thrift.TimedOutException
org.apache.thrift.TException
insert
public void insert(ByteBuffer key,
org.apache.cassandra.thrift.ColumnParent column_parent,
org.apache.cassandra.thrift.Column column,
org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
throws org.apache.cassandra.thrift.InvalidRequestException,
org.apache.cassandra.thrift.UnavailableException,
org.apache.cassandra.thrift.TimedOutException,
org.apache.thrift.TException
- Specified by:
insert
in interface org.apache.cassandra.thrift.Cassandra.Iface
- Overrides:
insert
in class AbstractThriftClientWrapper
- Throws:
org.apache.cassandra.thrift.InvalidRequestException
org.apache.cassandra.thrift.UnavailableException
org.apache.cassandra.thrift.TimedOutException
org.apache.thrift.TException
multiget_count
public Map<ByteBuffer,Integer> multiget_count(List<ByteBuffer> keys,
org.apache.cassandra.thrift.ColumnParent column_parent,
org.apache.cassandra.thrift.SlicePredicate predicate,
org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
throws org.apache.cassandra.thrift.InvalidRequestException,
org.apache.cassandra.thrift.UnavailableException,
org.apache.cassandra.thrift.TimedOutException,
org.apache.thrift.TException
- Specified by:
multiget_count
in interface org.apache.cassandra.thrift.Cassandra.Iface
- Overrides:
multiget_count
in class AbstractThriftClientWrapper
- Throws:
org.apache.cassandra.thrift.InvalidRequestException
org.apache.cassandra.thrift.UnavailableException
org.apache.cassandra.thrift.TimedOutException
org.apache.thrift.TException
multiget_slice
public Map<ByteBuffer,List<org.apache.cassandra.thrift.ColumnOrSuperColumn>> multiget_slice(List<ByteBuffer> keys,
org.apache.cassandra.thrift.ColumnParent column_parent,
org.apache.cassandra.thrift.SlicePredicate predicate,
org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
throws org.apache.cassandra.thrift.InvalidRequestException,
org.apache.cassandra.thrift.UnavailableException,
org.apache.cassandra.thrift.TimedOutException,
org.apache.thrift.TException
- Specified by:
multiget_slice
in interface org.apache.cassandra.thrift.Cassandra.Iface
- Overrides:
multiget_slice
in class AbstractThriftClientWrapper
- Throws:
org.apache.cassandra.thrift.InvalidRequestException
org.apache.cassandra.thrift.UnavailableException
org.apache.cassandra.thrift.TimedOutException
org.apache.thrift.TException
remove
public void remove(ByteBuffer key,
org.apache.cassandra.thrift.ColumnPath column_path,
long timestamp,
org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
throws org.apache.cassandra.thrift.InvalidRequestException,
org.apache.cassandra.thrift.UnavailableException,
org.apache.cassandra.thrift.TimedOutException,
org.apache.thrift.TException
- Specified by:
remove
in interface org.apache.cassandra.thrift.Cassandra.Iface
- Overrides:
remove
in class AbstractThriftClientWrapper
- Throws:
org.apache.cassandra.thrift.InvalidRequestException
org.apache.cassandra.thrift.UnavailableException
org.apache.cassandra.thrift.TimedOutException
org.apache.thrift.TException
remove_counter
public void remove_counter(ByteBuffer key,
org.apache.cassandra.thrift.ColumnPath path,
org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
throws org.apache.cassandra.thrift.InvalidRequestException,
org.apache.cassandra.thrift.UnavailableException,
org.apache.cassandra.thrift.TimedOutException,
org.apache.thrift.TException
- Specified by:
remove_counter
in interface org.apache.cassandra.thrift.Cassandra.Iface
- Overrides:
remove_counter
in class AbstractThriftClientWrapper
- Throws:
org.apache.cassandra.thrift.InvalidRequestException
org.apache.cassandra.thrift.UnavailableException
org.apache.cassandra.thrift.TimedOutException
org.apache.thrift.TException
Copyright © 2011. All Rights Reserved.