|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.cassandra.thrift.Cassandra.Client
public static class Cassandra.Client
Field Summary | |
---|---|
protected org.apache.thrift.protocol.TProtocol |
iprot_
|
protected org.apache.thrift.protocol.TProtocol |
oprot_
|
protected int |
seqid_
|
Constructor Summary | |
---|---|
Cassandra.Client(org.apache.thrift.protocol.TProtocol prot)
|
|
Cassandra.Client(org.apache.thrift.protocol.TProtocol iprot,
org.apache.thrift.protocol.TProtocol oprot)
|
Method Summary | |
---|---|
void |
batch_insert(java.lang.String keyspace,
java.lang.String key,
java.util.Map<java.lang.String,java.util.List<ColumnOrSuperColumn>> cfmap,
ConsistencyLevel consistency_level)
Insert Columns or SuperColumns across different Column Families for the same row key. |
void |
batch_mutate(java.lang.String keyspace,
java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.util.List<Mutation>>> mutation_map,
ConsistencyLevel consistency_level)
Mutate many columns or super columns for many row keys. |
java.lang.String |
describe_cluster_name()
get the cluster name |
java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>> |
describe_keyspace(java.lang.String keyspace)
describe specified keyspace |
java.util.Set<java.lang.String> |
describe_keyspaces()
list the defined keyspaces in this cluster |
java.lang.String |
describe_partitioner()
returns the partitioner used by this cluster |
java.util.List<TokenRange> |
describe_ring(java.lang.String keyspace)
get the token ring: a map of ranges to host addresses, represented as a set of TokenRange instead of a map from range to list of endpoints, because you can't use Thrift structs as map keys: https://issues.apache.org/jira/browse/THRIFT-162 for the same reason, we can't return a set here, even though order is neither important nor predictable. |
java.util.List<java.lang.String> |
describe_splits(java.lang.String start_token,
java.lang.String end_token,
int keys_per_split)
experimental API for hadoop/parallel query support. |
java.lang.String |
describe_version()
get the thrift api version |
int |
get_count(java.lang.String keyspace,
java.lang.String key,
ColumnParent column_parent,
ConsistencyLevel consistency_level)
returns the number of columns for a particular key and ColumnFamily or SuperColumn . |
java.util.List<KeySlice> |
get_range_slice(java.lang.String keyspace,
ColumnParent column_parent,
SlicePredicate predicate,
java.lang.String start_key,
java.lang.String finish_key,
int row_count,
ConsistencyLevel consistency_level)
returns a subset of columns for a range of keys. |
java.util.List<KeySlice> |
get_range_slices(java.lang.String keyspace,
ColumnParent column_parent,
SlicePredicate predicate,
KeyRange range,
ConsistencyLevel consistency_level)
returns a subset of columns for a range of keys. |
java.util.List<ColumnOrSuperColumn> |
get_slice(java.lang.String keyspace,
java.lang.String key,
ColumnParent column_parent,
SlicePredicate predicate,
ConsistencyLevel consistency_level)
Get the group of columns contained by column_parent (either a ColumnFamily name or a ColumnFamily/SuperColumn name pair) specified by the given SlicePredicate. |
java.util.List<java.lang.String> |
get_string_list_property(java.lang.String property)
get property whose value is list of strings. |
java.lang.String |
get_string_property(java.lang.String property)
get property whose value is of type string. |
ColumnOrSuperColumn |
get(java.lang.String keyspace,
java.lang.String key,
ColumnPath column_path,
ConsistencyLevel consistency_level)
Get the Column or SuperColumn at the given column_path. |
org.apache.thrift.protocol.TProtocol |
getInputProtocol()
|
org.apache.thrift.protocol.TProtocol |
getOutputProtocol()
|
void |
insert(java.lang.String keyspace,
java.lang.String key,
ColumnPath column_path,
byte[] value,
long timestamp,
ConsistencyLevel consistency_level)
Insert a Column consisting of (column_path.column, value, timestamp) at the given column_path.column_family and optional column_path.super_column. |
void |
login(java.lang.String keyspace,
AuthenticationRequest auth_request)
|
java.util.Map<java.lang.String,java.util.List<ColumnOrSuperColumn>> |
multiget_slice(java.lang.String keyspace,
java.util.List<java.lang.String> keys,
ColumnParent column_parent,
SlicePredicate predicate,
ConsistencyLevel consistency_level)
Performs a get_slice for column_parent and predicate for the given keys in parallel. |
java.util.Map<java.lang.String,ColumnOrSuperColumn> |
multiget(java.lang.String keyspace,
java.util.List<java.lang.String> keys,
ColumnPath column_path,
ConsistencyLevel consistency_level)
Perform a get for column_path in parallel on the given list |
void |
recv_batch_insert()
|
void |
recv_batch_mutate()
|
java.lang.String |
recv_describe_cluster_name()
|
java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>> |
recv_describe_keyspace()
|
java.util.Set<java.lang.String> |
recv_describe_keyspaces()
|
java.lang.String |
recv_describe_partitioner()
|
java.util.List<TokenRange> |
recv_describe_ring()
|
java.util.List<java.lang.String> |
recv_describe_splits()
|
java.lang.String |
recv_describe_version()
|
int |
recv_get_count()
|
java.util.List<KeySlice> |
recv_get_range_slice()
|
java.util.List<KeySlice> |
recv_get_range_slices()
|
java.util.List<ColumnOrSuperColumn> |
recv_get_slice()
|
java.util.List<java.lang.String> |
recv_get_string_list_property()
|
java.lang.String |
recv_get_string_property()
|
ColumnOrSuperColumn |
recv_get()
|
void |
recv_insert()
|
void |
recv_login()
|
java.util.Map<java.lang.String,java.util.List<ColumnOrSuperColumn>> |
recv_multiget_slice()
|
java.util.Map<java.lang.String,ColumnOrSuperColumn> |
recv_multiget()
|
void |
recv_remove()
|
void |
remove(java.lang.String keyspace,
java.lang.String key,
ColumnPath column_path,
long timestamp,
ConsistencyLevel consistency_level)
Remove data from the row specified by key at the granularity specified by column_path, and the given timestamp. |
void |
send_batch_insert(java.lang.String keyspace,
java.lang.String key,
java.util.Map<java.lang.String,java.util.List<ColumnOrSuperColumn>> cfmap,
ConsistencyLevel consistency_level)
|
void |
send_batch_mutate(java.lang.String keyspace,
java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.util.List<Mutation>>> mutation_map,
ConsistencyLevel consistency_level)
|
void |
send_describe_cluster_name()
|
void |
send_describe_keyspace(java.lang.String keyspace)
|
void |
send_describe_keyspaces()
|
void |
send_describe_partitioner()
|
void |
send_describe_ring(java.lang.String keyspace)
|
void |
send_describe_splits(java.lang.String start_token,
java.lang.String end_token,
int keys_per_split)
|
void |
send_describe_version()
|
void |
send_get_count(java.lang.String keyspace,
java.lang.String key,
ColumnParent column_parent,
ConsistencyLevel consistency_level)
|
void |
send_get_range_slice(java.lang.String keyspace,
ColumnParent column_parent,
SlicePredicate predicate,
java.lang.String start_key,
java.lang.String finish_key,
int row_count,
ConsistencyLevel consistency_level)
|
void |
send_get_range_slices(java.lang.String keyspace,
ColumnParent column_parent,
SlicePredicate predicate,
KeyRange range,
ConsistencyLevel consistency_level)
|
void |
send_get_slice(java.lang.String keyspace,
java.lang.String key,
ColumnParent column_parent,
SlicePredicate predicate,
ConsistencyLevel consistency_level)
|
void |
send_get_string_list_property(java.lang.String property)
|
void |
send_get_string_property(java.lang.String property)
|
void |
send_get(java.lang.String keyspace,
java.lang.String key,
ColumnPath column_path,
ConsistencyLevel consistency_level)
|
void |
send_insert(java.lang.String keyspace,
java.lang.String key,
ColumnPath column_path,
byte[] value,
long timestamp,
ConsistencyLevel consistency_level)
|
void |
send_login(java.lang.String keyspace,
AuthenticationRequest auth_request)
|
void |
send_multiget_slice(java.lang.String keyspace,
java.util.List<java.lang.String> keys,
ColumnParent column_parent,
SlicePredicate predicate,
ConsistencyLevel consistency_level)
|
void |
send_multiget(java.lang.String keyspace,
java.util.List<java.lang.String> keys,
ColumnPath column_path,
ConsistencyLevel consistency_level)
|
void |
send_remove(java.lang.String keyspace,
java.lang.String key,
ColumnPath column_path,
long timestamp,
ConsistencyLevel consistency_level)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected org.apache.thrift.protocol.TProtocol iprot_
protected org.apache.thrift.protocol.TProtocol oprot_
protected int seqid_
Constructor Detail |
---|
public Cassandra.Client(org.apache.thrift.protocol.TProtocol prot)
public Cassandra.Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot)
Method Detail |
---|
public org.apache.thrift.protocol.TProtocol getInputProtocol()
public org.apache.thrift.protocol.TProtocol getOutputProtocol()
public void login(java.lang.String keyspace, AuthenticationRequest auth_request) throws AuthenticationException, AuthorizationException, org.apache.thrift.TException
login
in interface Cassandra.Iface
AuthenticationException
AuthorizationException
org.apache.thrift.TException
public void send_login(java.lang.String keyspace, AuthenticationRequest auth_request) throws org.apache.thrift.TException
org.apache.thrift.TException
public void recv_login() throws AuthenticationException, AuthorizationException, org.apache.thrift.TException
AuthenticationException
AuthorizationException
org.apache.thrift.TException
public ColumnOrSuperColumn get(java.lang.String keyspace, java.lang.String key, ColumnPath column_path, ConsistencyLevel consistency_level) throws InvalidRequestException, NotFoundException, UnavailableException, TimedOutException, org.apache.thrift.TException
Cassandra.Iface
get
in interface Cassandra.Iface
InvalidRequestException
NotFoundException
UnavailableException
TimedOutException
org.apache.thrift.TException
public void send_get(java.lang.String keyspace, java.lang.String key, ColumnPath column_path, ConsistencyLevel consistency_level) throws org.apache.thrift.TException
org.apache.thrift.TException
public ColumnOrSuperColumn recv_get() throws InvalidRequestException, NotFoundException, UnavailableException, TimedOutException, org.apache.thrift.TException
InvalidRequestException
NotFoundException
UnavailableException
TimedOutException
org.apache.thrift.TException
public java.util.List<ColumnOrSuperColumn> get_slice(java.lang.String keyspace, java.lang.String key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
Cassandra.Iface
get_slice
in interface Cassandra.Iface
InvalidRequestException
UnavailableException
TimedOutException
org.apache.thrift.TException
public void send_get_slice(java.lang.String keyspace, java.lang.String key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws org.apache.thrift.TException
org.apache.thrift.TException
public java.util.List<ColumnOrSuperColumn> recv_get_slice() throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
InvalidRequestException
UnavailableException
TimedOutException
org.apache.thrift.TException
public java.util.Map<java.lang.String,ColumnOrSuperColumn> multiget(java.lang.String keyspace, java.util.List<java.lang.String> keys, ColumnPath column_path, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
Cassandra.Iface
multiget
in interface Cassandra.Iface
InvalidRequestException
UnavailableException
TimedOutException
org.apache.thrift.TException
public void send_multiget(java.lang.String keyspace, java.util.List<java.lang.String> keys, ColumnPath column_path, ConsistencyLevel consistency_level) throws org.apache.thrift.TException
org.apache.thrift.TException
public java.util.Map<java.lang.String,ColumnOrSuperColumn> recv_multiget() throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
InvalidRequestException
UnavailableException
TimedOutException
org.apache.thrift.TException
public java.util.Map<java.lang.String,java.util.List<ColumnOrSuperColumn>> multiget_slice(java.lang.String keyspace, java.util.List<java.lang.String> keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
Cassandra.Iface
multiget_slice
in interface Cassandra.Iface
InvalidRequestException
UnavailableException
TimedOutException
org.apache.thrift.TException
public void send_multiget_slice(java.lang.String keyspace, java.util.List<java.lang.String> keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws org.apache.thrift.TException
org.apache.thrift.TException
public java.util.Map<java.lang.String,java.util.List<ColumnOrSuperColumn>> recv_multiget_slice() throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
InvalidRequestException
UnavailableException
TimedOutException
org.apache.thrift.TException
public int get_count(java.lang.String keyspace, java.lang.String key, ColumnParent column_parent, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
Cassandra.Iface
key
and ColumnFamily
or SuperColumn
.
get_count
in interface Cassandra.Iface
InvalidRequestException
UnavailableException
TimedOutException
org.apache.thrift.TException
public void send_get_count(java.lang.String keyspace, java.lang.String key, ColumnParent column_parent, ConsistencyLevel consistency_level) throws org.apache.thrift.TException
org.apache.thrift.TException
public int recv_get_count() throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
InvalidRequestException
UnavailableException
TimedOutException
org.apache.thrift.TException
public java.util.List<KeySlice> get_range_slice(java.lang.String keyspace, ColumnParent column_parent, SlicePredicate predicate, java.lang.String start_key, java.lang.String finish_key, int row_count, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
Cassandra.Iface
get_range_slice
in interface Cassandra.Iface
InvalidRequestException
UnavailableException
TimedOutException
org.apache.thrift.TException
public void send_get_range_slice(java.lang.String keyspace, ColumnParent column_parent, SlicePredicate predicate, java.lang.String start_key, java.lang.String finish_key, int row_count, ConsistencyLevel consistency_level) throws org.apache.thrift.TException
org.apache.thrift.TException
public java.util.List<KeySlice> recv_get_range_slice() throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
InvalidRequestException
UnavailableException
TimedOutException
org.apache.thrift.TException
public java.util.List<KeySlice> get_range_slices(java.lang.String keyspace, ColumnParent column_parent, SlicePredicate predicate, KeyRange range, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
Cassandra.Iface
get_range_slices
in interface Cassandra.Iface
InvalidRequestException
UnavailableException
TimedOutException
org.apache.thrift.TException
public void send_get_range_slices(java.lang.String keyspace, ColumnParent column_parent, SlicePredicate predicate, KeyRange range, ConsistencyLevel consistency_level) throws org.apache.thrift.TException
org.apache.thrift.TException
public java.util.List<KeySlice> recv_get_range_slices() throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
InvalidRequestException
UnavailableException
TimedOutException
org.apache.thrift.TException
public void insert(java.lang.String keyspace, java.lang.String key, ColumnPath column_path, byte[] value, long timestamp, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
Cassandra.Iface
insert
in interface Cassandra.Iface
InvalidRequestException
UnavailableException
TimedOutException
org.apache.thrift.TException
public void send_insert(java.lang.String keyspace, java.lang.String key, ColumnPath column_path, byte[] value, long timestamp, ConsistencyLevel consistency_level) throws org.apache.thrift.TException
org.apache.thrift.TException
public void recv_insert() throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
InvalidRequestException
UnavailableException
TimedOutException
org.apache.thrift.TException
public void batch_insert(java.lang.String keyspace, java.lang.String key, java.util.Map<java.lang.String,java.util.List<ColumnOrSuperColumn>> cfmap, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
Cassandra.Iface
batch_insert
in interface Cassandra.Iface
InvalidRequestException
UnavailableException
TimedOutException
org.apache.thrift.TException
public void send_batch_insert(java.lang.String keyspace, java.lang.String key, java.util.Map<java.lang.String,java.util.List<ColumnOrSuperColumn>> cfmap, ConsistencyLevel consistency_level) throws org.apache.thrift.TException
org.apache.thrift.TException
public void recv_batch_insert() throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
InvalidRequestException
UnavailableException
TimedOutException
org.apache.thrift.TException
public void remove(java.lang.String keyspace, java.lang.String key, ColumnPath column_path, long timestamp, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
Cassandra.Iface
remove
in interface Cassandra.Iface
InvalidRequestException
UnavailableException
TimedOutException
org.apache.thrift.TException
public void send_remove(java.lang.String keyspace, java.lang.String key, ColumnPath column_path, long timestamp, ConsistencyLevel consistency_level) throws org.apache.thrift.TException
org.apache.thrift.TException
public void recv_remove() throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
InvalidRequestException
UnavailableException
TimedOutException
org.apache.thrift.TException
public void batch_mutate(java.lang.String keyspace, java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.util.List<Mutation>>> mutation_map, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
Cassandra.Iface
batch_mutate
in interface Cassandra.Iface
InvalidRequestException
UnavailableException
TimedOutException
org.apache.thrift.TException
public void send_batch_mutate(java.lang.String keyspace, java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.util.List<Mutation>>> mutation_map, ConsistencyLevel consistency_level) throws org.apache.thrift.TException
org.apache.thrift.TException
public void recv_batch_mutate() throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
InvalidRequestException
UnavailableException
TimedOutException
org.apache.thrift.TException
public java.lang.String get_string_property(java.lang.String property) throws org.apache.thrift.TException
Cassandra.Iface
get_string_property
in interface Cassandra.Iface
org.apache.thrift.TException
public void send_get_string_property(java.lang.String property) throws org.apache.thrift.TException
org.apache.thrift.TException
public java.lang.String recv_get_string_property() throws org.apache.thrift.TException
org.apache.thrift.TException
public java.util.List<java.lang.String> get_string_list_property(java.lang.String property) throws org.apache.thrift.TException
Cassandra.Iface
get_string_list_property
in interface Cassandra.Iface
org.apache.thrift.TException
public void send_get_string_list_property(java.lang.String property) throws org.apache.thrift.TException
org.apache.thrift.TException
public java.util.List<java.lang.String> recv_get_string_list_property() throws org.apache.thrift.TException
org.apache.thrift.TException
public java.util.Set<java.lang.String> describe_keyspaces() throws org.apache.thrift.TException
Cassandra.Iface
describe_keyspaces
in interface Cassandra.Iface
org.apache.thrift.TException
public void send_describe_keyspaces() throws org.apache.thrift.TException
org.apache.thrift.TException
public java.util.Set<java.lang.String> recv_describe_keyspaces() throws org.apache.thrift.TException
org.apache.thrift.TException
public java.lang.String describe_cluster_name() throws org.apache.thrift.TException
Cassandra.Iface
describe_cluster_name
in interface Cassandra.Iface
org.apache.thrift.TException
public void send_describe_cluster_name() throws org.apache.thrift.TException
org.apache.thrift.TException
public java.lang.String recv_describe_cluster_name() throws org.apache.thrift.TException
org.apache.thrift.TException
public java.lang.String describe_version() throws org.apache.thrift.TException
Cassandra.Iface
describe_version
in interface Cassandra.Iface
org.apache.thrift.TException
public void send_describe_version() throws org.apache.thrift.TException
org.apache.thrift.TException
public java.lang.String recv_describe_version() throws org.apache.thrift.TException
org.apache.thrift.TException
public java.util.List<TokenRange> describe_ring(java.lang.String keyspace) throws InvalidRequestException, org.apache.thrift.TException
Cassandra.Iface
describe_ring
in interface Cassandra.Iface
InvalidRequestException
org.apache.thrift.TException
public void send_describe_ring(java.lang.String keyspace) throws org.apache.thrift.TException
org.apache.thrift.TException
public java.util.List<TokenRange> recv_describe_ring() throws InvalidRequestException, org.apache.thrift.TException
InvalidRequestException
org.apache.thrift.TException
public java.lang.String describe_partitioner() throws org.apache.thrift.TException
Cassandra.Iface
describe_partitioner
in interface Cassandra.Iface
org.apache.thrift.TException
public void send_describe_partitioner() throws org.apache.thrift.TException
org.apache.thrift.TException
public java.lang.String recv_describe_partitioner() throws org.apache.thrift.TException
org.apache.thrift.TException
public java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>> describe_keyspace(java.lang.String keyspace) throws NotFoundException, org.apache.thrift.TException
Cassandra.Iface
describe_keyspace
in interface Cassandra.Iface
NotFoundException
org.apache.thrift.TException
public void send_describe_keyspace(java.lang.String keyspace) throws org.apache.thrift.TException
org.apache.thrift.TException
public java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>> recv_describe_keyspace() throws NotFoundException, org.apache.thrift.TException
NotFoundException
org.apache.thrift.TException
public java.util.List<java.lang.String> describe_splits(java.lang.String start_token, java.lang.String end_token, int keys_per_split) throws org.apache.thrift.TException
Cassandra.Iface
describe_splits
in interface Cassandra.Iface
org.apache.thrift.TException
public void send_describe_splits(java.lang.String start_token, java.lang.String end_token, int keys_per_split) throws org.apache.thrift.TException
org.apache.thrift.TException
public java.util.List<java.lang.String> recv_describe_splits() throws org.apache.thrift.TException
org.apache.thrift.TException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |