http://git-wip-us.apache.org/repos/asf/cassandra-dtest/blob/49b2dda4/thrift_bindings/v22/Cassandra.py ---------------------------------------------------------------------- diff --git a/thrift_bindings/v22/Cassandra.py b/thrift_bindings/v22/Cassandra.py deleted file mode 100644 index 1e7dd0e..0000000 --- a/thrift_bindings/v22/Cassandra.py +++ /dev/null @@ -1,10506 +0,0 @@ -# -# Autogenerated by Thrift Compiler (0.9.0) -# -# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING -# -# options string: py -# - -from thrift.protocol import TBinaryProtocol, TProtocol -from thrift.Thrift import (TApplicationException, TException, TMessageType, - TProcessor, TType) -from thrift.transport import TTransport - -from ttypes import * - -try: - from thrift.protocol import fastbinary -except: - fastbinary = None - - -class Iface: - def login(self, auth_request): - """ - Parameters: - - auth_request - """ - pass - - def set_keyspace(self, keyspace): - """ - Parameters: - - keyspace - """ - pass - - def get(self, key, column_path, consistency_level): - """ - Get the Column or SuperColumn at the given column_path. If no value is present, NotFoundException is thrown. (This is - the only method that can throw an exception under non-failure conditions.) - - Parameters: - - key - - column_path - - consistency_level - """ - pass - - def get_slice(self, key, column_parent, predicate, 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. If no matching values are found, an empty list is returned. - - Parameters: - - key - - column_parent - - predicate - - consistency_level - """ - pass - - def get_count(self, key, column_parent, predicate, consistency_level): - """ - returns the number of columns matching <code>predicate</code> for a particular <code>key</code>, - <code>ColumnFamily</code> and optionally <code>SuperColumn</code>. - - Parameters: - - key - - column_parent - - predicate - - consistency_level - """ - pass - - def multiget_slice(self, keys, column_parent, predicate, consistency_level): - """ - Performs a get_slice for column_parent and predicate for the given keys in parallel. - - Parameters: - - keys - - column_parent - - predicate - - consistency_level - """ - pass - - def multiget_count(self, keys, column_parent, predicate, consistency_level): - """ - Perform a get_count in parallel on the given list<binary> keys. The return value maps keys to the count found. - - Parameters: - - keys - - column_parent - - predicate - - consistency_level - """ - pass - - def get_range_slices(self, column_parent, predicate, range, consistency_level): - """ - returns a subset of columns for a contiguous range of keys. - - Parameters: - - column_parent - - predicate - - range - - consistency_level - """ - pass - - def get_paged_slice(self, column_family, range, start_column, consistency_level): - """ - returns a range of columns, wrapping to the next rows if necessary to collect max_results. - - Parameters: - - column_family - - range - - start_column - - consistency_level - """ - pass - - def get_indexed_slices(self, column_parent, index_clause, column_predicate, consistency_level): - """ - Returns the subset of columns specified in SlicePredicate for the rows matching the IndexClause - @deprecated use get_range_slices instead with range.row_filter specified - - Parameters: - - column_parent - - index_clause - - column_predicate - - consistency_level - """ - pass - - def insert(self, key, column_parent, column, consistency_level): - """ - Insert a Column at the given column_parent.column_family and optional column_parent.super_column. - - Parameters: - - key - - column_parent - - column - - consistency_level - """ - pass - - def add(self, key, column_parent, column, consistency_level): - """ - Increment or decrement a counter. - - Parameters: - - key - - column_parent - - column - - consistency_level - """ - pass - - def cas(self, key, column_family, expected, updates, serial_consistency_level, commit_consistency_level): - """ - Atomic compare and set. - - If the cas is successfull, the success boolean in CASResult will be true and there will be no current_values. - Otherwise, success will be false and current_values will contain the current values for the columns in - expected (that, by definition of compare-and-set, will differ from the values in expected). - - A cas operation takes 2 consistency level. The first one, serial_consistency_level, simply indicates the - level of serialization required. This can be either ConsistencyLevel.SERIAL or ConsistencyLevel.LOCAL_SERIAL. - The second one, commit_consistency_level, defines the consistency level for the commit phase of the cas. This - is a more traditional consistency level (the same CL than for traditional writes are accepted) that impact - the visibility for reads of the operation. For instance, if commit_consistency_level is QUORUM, then it is - guaranteed that a followup QUORUM read will see the cas write (if that one was successful obviously). If - commit_consistency_level is ANY, you will need to use a SERIAL/LOCAL_SERIAL read to be guaranteed to see - the write. - - Parameters: - - key - - column_family - - expected - - updates - - serial_consistency_level - - commit_consistency_level - """ - pass - - def remove(self, key, column_path, timestamp, consistency_level): - """ - Remove data from the row specified by key at the granularity specified by column_path, and the given timestamp. Note - that all the values in column_path besides column_path.column_family are truly optional: you can remove the entire - row by just specifying the ColumnFamily, or you can remove a SuperColumn or a single Column by specifying those levels too. - - Parameters: - - key - - column_path - - timestamp - - consistency_level - """ - pass - - def remove_counter(self, key, path, consistency_level): - """ - Remove a counter at the specified location. - Note that counters have limited support for deletes: if you remove a counter, you must wait to issue any following update - until the delete has reached all the nodes and all of them have been fully compacted. - - Parameters: - - key - - path - - consistency_level - """ - pass - - def batch_mutate(self, mutation_map, consistency_level): - """ - Mutate many columns or super columns for many row keys. See also: Mutation. - - mutation_map maps key to column family to a list of Mutation objects to take place at that scope. - * - - Parameters: - - mutation_map - - consistency_level - """ - pass - - def atomic_batch_mutate(self, mutation_map, consistency_level): - """ - Atomically mutate many columns or super columns for many row keys. See also: Mutation. - - mutation_map maps key to column family to a list of Mutation objects to take place at that scope. - * - - Parameters: - - mutation_map - - consistency_level - """ - pass - - def truncate(self, cfname): - """ - Truncate will mark and entire column family as deleted. - From the user's perspective a successful call to truncate will result complete data deletion from cfname. - Internally, however, disk space will not be immediatily released, as with all deletes in cassandra, this one - only marks the data as deleted. - The operation succeeds only if all hosts in the cluster at available and will throw an UnavailableException if - some hosts are down. - - Parameters: - - cfname - """ - pass - - def get_multi_slice(self, request): - """ - Select multiple slices of a key in a single RPC operation - - Parameters: - - request - """ - pass - - def describe_schema_versions(self, ): - """ - for each schema version present in the cluster, returns a list of nodes at that version. - hosts that do not respond will be under the key DatabaseDescriptor.INITIAL_VERSION. - the cluster is all on the same version if the size of the map is 1. - """ - pass - - def describe_keyspaces(self, ): - """ - list the defined keyspaces in this cluster - """ - pass - - def describe_cluster_name(self, ): - """ - get the cluster name - """ - pass - - def describe_version(self, ): - """ - get the thrift api version - """ - pass - - def describe_ring(self, 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. - - Parameters: - - keyspace - """ - pass - - def describe_local_ring(self, keyspace): - """ - same as describe_ring, but considers only nodes in the local DC - - Parameters: - - keyspace - """ - pass - - def describe_token_map(self, ): - """ - get the mapping between token->node ip - without taking replication into consideration - https://issues.apache.org/jira/browse/CASSANDRA-4092 - """ - pass - - def describe_partitioner(self, ): - """ - returns the partitioner used by this cluster - """ - pass - - def describe_snitch(self, ): - """ - returns the snitch used by this cluster - """ - pass - - def describe_keyspace(self, keyspace): - """ - describe specified keyspace - - Parameters: - - keyspace - """ - pass - - def describe_splits(self, cfName, start_token, end_token, keys_per_split): - """ - experimental API for hadoop/parallel query support. - may change violently and without warning. - - returns list of token strings such that first subrange is (list[0], list[1]], - next is (list[1], list[2]], etc. - - Parameters: - - cfName - - start_token - - end_token - - keys_per_split - """ - pass - - def trace_next_query(self, ): - """ - Enables tracing for the next query in this connection and returns the UUID for that trace session - The next query will be traced idependently of trace probability and the returned UUID can be used to query the trace keyspace - """ - pass - - def describe_splits_ex(self, cfName, start_token, end_token, keys_per_split): - """ - Parameters: - - cfName - - start_token - - end_token - - keys_per_split - """ - pass - - def system_add_column_family(self, cf_def): - """ - adds a column family. returns the new schema id. - - Parameters: - - cf_def - """ - pass - - def system_drop_column_family(self, column_family): - """ - drops a column family. returns the new schema id. - - Parameters: - - column_family - """ - pass - - def system_add_keyspace(self, ks_def): - """ - adds a keyspace and any column families that are part of it. returns the new schema id. - - Parameters: - - ks_def - """ - pass - - def system_drop_keyspace(self, keyspace): - """ - drops a keyspace and any column families that are part of it. returns the new schema id. - - Parameters: - - keyspace - """ - pass - - def system_update_keyspace(self, ks_def): - """ - updates properties of a keyspace. returns the new schema id. - - Parameters: - - ks_def - """ - pass - - def system_update_column_family(self, cf_def): - """ - updates properties of a column family. returns the new schema id. - - Parameters: - - cf_def - """ - pass - - def execute_cql_query(self, query, compression): - """ - @deprecated Throws InvalidRequestException since 2.2. Please use the CQL3 version instead. - - Parameters: - - query - - compression - """ - pass - - def execute_cql3_query(self, query, compression, consistency): - """ - Executes a CQL3 (Cassandra Query Language) statement and returns a - CqlResult containing the results. - - Parameters: - - query - - compression - - consistency - """ - pass - - def prepare_cql_query(self, query, compression): - """ - @deprecated Throws InvalidRequestException since 2.2. Please use the CQL3 version instead. - - Parameters: - - query - - compression - """ - pass - - def prepare_cql3_query(self, query, compression): - """ - Prepare a CQL3 (Cassandra Query Language) statement by compiling and returning - - the type of CQL statement - - an id token of the compiled CQL stored on the server side. - - a count of the discovered bound markers in the statement - - Parameters: - - query - - compression - """ - pass - - def execute_prepared_cql_query(self, itemId, values): - """ - @deprecated Throws InvalidRequestException since 2.2. Please use the CQL3 version instead. - - Parameters: - - itemId - - values - """ - pass - - def execute_prepared_cql3_query(self, itemId, values, consistency): - """ - Executes a prepared CQL3 (Cassandra Query Language) statement by passing an id token, a list of variables - to bind, and the consistency level, and returns a CqlResult containing the results. - - Parameters: - - itemId - - values - - consistency - """ - pass - - def set_cql_version(self, version): - """ - @deprecated This is now a no-op. Please use the CQL3 specific methods instead. - - Parameters: - - version - """ - pass - - -class Client(Iface): - def __init__(self, iprot, oprot=None): - self._iprot = self._oprot = iprot - if oprot is not None: - self._oprot = oprot - self._seqid = 0 - - def login(self, auth_request): - """ - Parameters: - - auth_request - """ - self.send_login(auth_request) - self.recv_login() - - def send_login(self, auth_request): - self._oprot.writeMessageBegin('login', TMessageType.CALL, self._seqid) - args = login_args() - args.auth_request = auth_request - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_login(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = login_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.authnx is not None: - raise result.authnx - if result.authzx is not None: - raise result.authzx - return - - def set_keyspace(self, keyspace): - """ - Parameters: - - keyspace - """ - self.send_set_keyspace(keyspace) - self.recv_set_keyspace() - - def send_set_keyspace(self, keyspace): - self._oprot.writeMessageBegin('set_keyspace', TMessageType.CALL, self._seqid) - args = set_keyspace_args() - args.keyspace = keyspace - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_set_keyspace(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = set_keyspace_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.ire is not None: - raise result.ire - return - - def get(self, key, column_path, consistency_level): - """ - Get the Column or SuperColumn at the given column_path. If no value is present, NotFoundException is thrown. (This is - the only method that can throw an exception under non-failure conditions.) - - Parameters: - - key - - column_path - - consistency_level - """ - self.send_get(key, column_path, consistency_level) - return self.recv_get() - - def send_get(self, key, column_path, consistency_level): - self._oprot.writeMessageBegin('get', TMessageType.CALL, self._seqid) - args = get_args() - args.key = key - args.column_path = column_path - args.consistency_level = consistency_level - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_get(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = get_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.ire is not None: - raise result.ire - if result.nfe is not None: - raise result.nfe - if result.ue is not None: - raise result.ue - if result.te is not None: - raise result.te - raise TApplicationException(TApplicationException.MISSING_RESULT, "get failed: unknown result"); - - def get_slice(self, key, column_parent, predicate, 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. If no matching values are found, an empty list is returned. - - Parameters: - - key - - column_parent - - predicate - - consistency_level - """ - self.send_get_slice(key, column_parent, predicate, consistency_level) - return self.recv_get_slice() - - def send_get_slice(self, key, column_parent, predicate, consistency_level): - self._oprot.writeMessageBegin('get_slice', TMessageType.CALL, self._seqid) - args = get_slice_args() - args.key = key - args.column_parent = column_parent - args.predicate = predicate - args.consistency_level = consistency_level - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_get_slice(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = get_slice_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.ire is not None: - raise result.ire - if result.ue is not None: - raise result.ue - if result.te is not None: - raise result.te - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_slice failed: unknown result"); - - def get_count(self, key, column_parent, predicate, consistency_level): - """ - returns the number of columns matching <code>predicate</code> for a particular <code>key</code>, - <code>ColumnFamily</code> and optionally <code>SuperColumn</code>. - - Parameters: - - key - - column_parent - - predicate - - consistency_level - """ - self.send_get_count(key, column_parent, predicate, consistency_level) - return self.recv_get_count() - - def send_get_count(self, key, column_parent, predicate, consistency_level): - self._oprot.writeMessageBegin('get_count', TMessageType.CALL, self._seqid) - args = get_count_args() - args.key = key - args.column_parent = column_parent - args.predicate = predicate - args.consistency_level = consistency_level - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_get_count(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = get_count_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.ire is not None: - raise result.ire - if result.ue is not None: - raise result.ue - if result.te is not None: - raise result.te - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_count failed: unknown result"); - - def multiget_slice(self, keys, column_parent, predicate, consistency_level): - """ - Performs a get_slice for column_parent and predicate for the given keys in parallel. - - Parameters: - - keys - - column_parent - - predicate - - consistency_level - """ - self.send_multiget_slice(keys, column_parent, predicate, consistency_level) - return self.recv_multiget_slice() - - def send_multiget_slice(self, keys, column_parent, predicate, consistency_level): - self._oprot.writeMessageBegin('multiget_slice', TMessageType.CALL, self._seqid) - args = multiget_slice_args() - args.keys = keys - args.column_parent = column_parent - args.predicate = predicate - args.consistency_level = consistency_level - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_multiget_slice(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = multiget_slice_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.ire is not None: - raise result.ire - if result.ue is not None: - raise result.ue - if result.te is not None: - raise result.te - raise TApplicationException(TApplicationException.MISSING_RESULT, "multiget_slice failed: unknown result"); - - def multiget_count(self, keys, column_parent, predicate, consistency_level): - """ - Perform a get_count in parallel on the given list<binary> keys. The return value maps keys to the count found. - - Parameters: - - keys - - column_parent - - predicate - - consistency_level - """ - self.send_multiget_count(keys, column_parent, predicate, consistency_level) - return self.recv_multiget_count() - - def send_multiget_count(self, keys, column_parent, predicate, consistency_level): - self._oprot.writeMessageBegin('multiget_count', TMessageType.CALL, self._seqid) - args = multiget_count_args() - args.keys = keys - args.column_parent = column_parent - args.predicate = predicate - args.consistency_level = consistency_level - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_multiget_count(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = multiget_count_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.ire is not None: - raise result.ire - if result.ue is not None: - raise result.ue - if result.te is not None: - raise result.te - raise TApplicationException(TApplicationException.MISSING_RESULT, "multiget_count failed: unknown result"); - - def get_range_slices(self, column_parent, predicate, range, consistency_level): - """ - returns a subset of columns for a contiguous range of keys. - - Parameters: - - column_parent - - predicate - - range - - consistency_level - """ - self.send_get_range_slices(column_parent, predicate, range, consistency_level) - return self.recv_get_range_slices() - - def send_get_range_slices(self, column_parent, predicate, range, consistency_level): - self._oprot.writeMessageBegin('get_range_slices', TMessageType.CALL, self._seqid) - args = get_range_slices_args() - args.column_parent = column_parent - args.predicate = predicate - args.range = range - args.consistency_level = consistency_level - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_get_range_slices(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = get_range_slices_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.ire is not None: - raise result.ire - if result.ue is not None: - raise result.ue - if result.te is not None: - raise result.te - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_range_slices failed: unknown result"); - - def get_paged_slice(self, column_family, range, start_column, consistency_level): - """ - returns a range of columns, wrapping to the next rows if necessary to collect max_results. - - Parameters: - - column_family - - range - - start_column - - consistency_level - """ - self.send_get_paged_slice(column_family, range, start_column, consistency_level) - return self.recv_get_paged_slice() - - def send_get_paged_slice(self, column_family, range, start_column, consistency_level): - self._oprot.writeMessageBegin('get_paged_slice', TMessageType.CALL, self._seqid) - args = get_paged_slice_args() - args.column_family = column_family - args.range = range - args.start_column = start_column - args.consistency_level = consistency_level - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_get_paged_slice(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = get_paged_slice_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.ire is not None: - raise result.ire - if result.ue is not None: - raise result.ue - if result.te is not None: - raise result.te - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_paged_slice failed: unknown result"); - - def get_indexed_slices(self, column_parent, index_clause, column_predicate, consistency_level): - """ - Returns the subset of columns specified in SlicePredicate for the rows matching the IndexClause - @deprecated use get_range_slices instead with range.row_filter specified - - Parameters: - - column_parent - - index_clause - - column_predicate - - consistency_level - """ - self.send_get_indexed_slices(column_parent, index_clause, column_predicate, consistency_level) - return self.recv_get_indexed_slices() - - def send_get_indexed_slices(self, column_parent, index_clause, column_predicate, consistency_level): - self._oprot.writeMessageBegin('get_indexed_slices', TMessageType.CALL, self._seqid) - args = get_indexed_slices_args() - args.column_parent = column_parent - args.index_clause = index_clause - args.column_predicate = column_predicate - args.consistency_level = consistency_level - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_get_indexed_slices(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = get_indexed_slices_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.ire is not None: - raise result.ire - if result.ue is not None: - raise result.ue - if result.te is not None: - raise result.te - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_indexed_slices failed: unknown result"); - - def insert(self, key, column_parent, column, consistency_level): - """ - Insert a Column at the given column_parent.column_family and optional column_parent.super_column. - - Parameters: - - key - - column_parent - - column - - consistency_level - """ - self.send_insert(key, column_parent, column, consistency_level) - self.recv_insert() - - def send_insert(self, key, column_parent, column, consistency_level): - self._oprot.writeMessageBegin('insert', TMessageType.CALL, self._seqid) - args = insert_args() - args.key = key - args.column_parent = column_parent - args.column = column - args.consistency_level = consistency_level - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_insert(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = insert_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.ire is not None: - raise result.ire - if result.ue is not None: - raise result.ue - if result.te is not None: - raise result.te - return - - def add(self, key, column_parent, column, consistency_level): - """ - Increment or decrement a counter. - - Parameters: - - key - - column_parent - - column - - consistency_level - """ - self.send_add(key, column_parent, column, consistency_level) - self.recv_add() - - def send_add(self, key, column_parent, column, consistency_level): - self._oprot.writeMessageBegin('add', TMessageType.CALL, self._seqid) - args = add_args() - args.key = key - args.column_parent = column_parent - args.column = column - args.consistency_level = consistency_level - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_add(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = add_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.ire is not None: - raise result.ire - if result.ue is not None: - raise result.ue - if result.te is not None: - raise result.te - return - - def cas(self, key, column_family, expected, updates, serial_consistency_level, commit_consistency_level): - """ - Atomic compare and set. - - If the cas is successfull, the success boolean in CASResult will be true and there will be no current_values. - Otherwise, success will be false and current_values will contain the current values for the columns in - expected (that, by definition of compare-and-set, will differ from the values in expected). - - A cas operation takes 2 consistency level. The first one, serial_consistency_level, simply indicates the - level of serialization required. This can be either ConsistencyLevel.SERIAL or ConsistencyLevel.LOCAL_SERIAL. - The second one, commit_consistency_level, defines the consistency level for the commit phase of the cas. This - is a more traditional consistency level (the same CL than for traditional writes are accepted) that impact - the visibility for reads of the operation. For instance, if commit_consistency_level is QUORUM, then it is - guaranteed that a followup QUORUM read will see the cas write (if that one was successful obviously). If - commit_consistency_level is ANY, you will need to use a SERIAL/LOCAL_SERIAL read to be guaranteed to see - the write. - - Parameters: - - key - - column_family - - expected - - updates - - serial_consistency_level - - commit_consistency_level - """ - self.send_cas(key, column_family, expected, updates, serial_consistency_level, commit_consistency_level) - return self.recv_cas() - - def send_cas(self, key, column_family, expected, updates, serial_consistency_level, commit_consistency_level): - self._oprot.writeMessageBegin('cas', TMessageType.CALL, self._seqid) - args = cas_args() - args.key = key - args.column_family = column_family - args.expected = expected - args.updates = updates - args.serial_consistency_level = serial_consistency_level - args.commit_consistency_level = commit_consistency_level - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_cas(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = cas_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.ire is not None: - raise result.ire - if result.ue is not None: - raise result.ue - if result.te is not None: - raise result.te - raise TApplicationException(TApplicationException.MISSING_RESULT, "cas failed: unknown result"); - - def remove(self, key, column_path, timestamp, consistency_level): - """ - Remove data from the row specified by key at the granularity specified by column_path, and the given timestamp. Note - that all the values in column_path besides column_path.column_family are truly optional: you can remove the entire - row by just specifying the ColumnFamily, or you can remove a SuperColumn or a single Column by specifying those levels too. - - Parameters: - - key - - column_path - - timestamp - - consistency_level - """ - self.send_remove(key, column_path, timestamp, consistency_level) - self.recv_remove() - - def send_remove(self, key, column_path, timestamp, consistency_level): - self._oprot.writeMessageBegin('remove', TMessageType.CALL, self._seqid) - args = remove_args() - args.key = key - args.column_path = column_path - args.timestamp = timestamp - args.consistency_level = consistency_level - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_remove(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = remove_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.ire is not None: - raise result.ire - if result.ue is not None: - raise result.ue - if result.te is not None: - raise result.te - return - - def remove_counter(self, key, path, consistency_level): - """ - Remove a counter at the specified location. - Note that counters have limited support for deletes: if you remove a counter, you must wait to issue any following update - until the delete has reached all the nodes and all of them have been fully compacted. - - Parameters: - - key - - path - - consistency_level - """ - self.send_remove_counter(key, path, consistency_level) - self.recv_remove_counter() - - def send_remove_counter(self, key, path, consistency_level): - self._oprot.writeMessageBegin('remove_counter', TMessageType.CALL, self._seqid) - args = remove_counter_args() - args.key = key - args.path = path - args.consistency_level = consistency_level - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_remove_counter(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = remove_counter_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.ire is not None: - raise result.ire - if result.ue is not None: - raise result.ue - if result.te is not None: - raise result.te - return - - def batch_mutate(self, mutation_map, consistency_level): - """ - Mutate many columns or super columns for many row keys. See also: Mutation. - - mutation_map maps key to column family to a list of Mutation objects to take place at that scope. - * - - Parameters: - - mutation_map - - consistency_level - """ - self.send_batch_mutate(mutation_map, consistency_level) - self.recv_batch_mutate() - - def send_batch_mutate(self, mutation_map, consistency_level): - self._oprot.writeMessageBegin('batch_mutate', TMessageType.CALL, self._seqid) - args = batch_mutate_args() - args.mutation_map = mutation_map - args.consistency_level = consistency_level - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_batch_mutate(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = batch_mutate_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.ire is not None: - raise result.ire - if result.ue is not None: - raise result.ue - if result.te is not None: - raise result.te - return - - def atomic_batch_mutate(self, mutation_map, consistency_level): - """ - Atomically mutate many columns or super columns for many row keys. See also: Mutation. - - mutation_map maps key to column family to a list of Mutation objects to take place at that scope. - * - - Parameters: - - mutation_map - - consistency_level - """ - self.send_atomic_batch_mutate(mutation_map, consistency_level) - self.recv_atomic_batch_mutate() - - def send_atomic_batch_mutate(self, mutation_map, consistency_level): - self._oprot.writeMessageBegin('atomic_batch_mutate', TMessageType.CALL, self._seqid) - args = atomic_batch_mutate_args() - args.mutation_map = mutation_map - args.consistency_level = consistency_level - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_atomic_batch_mutate(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = atomic_batch_mutate_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.ire is not None: - raise result.ire - if result.ue is not None: - raise result.ue - if result.te is not None: - raise result.te - return - - def truncate(self, cfname): - """ - Truncate will mark and entire column family as deleted. - From the user's perspective a successful call to truncate will result complete data deletion from cfname. - Internally, however, disk space will not be immediatily released, as with all deletes in cassandra, this one - only marks the data as deleted. - The operation succeeds only if all hosts in the cluster at available and will throw an UnavailableException if - some hosts are down. - - Parameters: - - cfname - """ - self.send_truncate(cfname) - self.recv_truncate() - - def send_truncate(self, cfname): - self._oprot.writeMessageBegin('truncate', TMessageType.CALL, self._seqid) - args = truncate_args() - args.cfname = cfname - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_truncate(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = truncate_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.ire is not None: - raise result.ire - if result.ue is not None: - raise result.ue - if result.te is not None: - raise result.te - return - - def get_multi_slice(self, request): - """ - Select multiple slices of a key in a single RPC operation - - Parameters: - - request - """ - self.send_get_multi_slice(request) - return self.recv_get_multi_slice() - - def send_get_multi_slice(self, request): - self._oprot.writeMessageBegin('get_multi_slice', TMessageType.CALL, self._seqid) - args = get_multi_slice_args() - args.request = request - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_get_multi_slice(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = get_multi_slice_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.ire is not None: - raise result.ire - if result.ue is not None: - raise result.ue - if result.te is not None: - raise result.te - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_multi_slice failed: unknown result"); - - def describe_schema_versions(self, ): - """ - for each schema version present in the cluster, returns a list of nodes at that version. - hosts that do not respond will be under the key DatabaseDescriptor.INITIAL_VERSION. - the cluster is all on the same version if the size of the map is 1. - """ - self.send_describe_schema_versions() - return self.recv_describe_schema_versions() - - def send_describe_schema_versions(self, ): - self._oprot.writeMessageBegin('describe_schema_versions', TMessageType.CALL, self._seqid) - args = describe_schema_versions_args() - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_describe_schema_versions(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = describe_schema_versions_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.ire is not None: - raise result.ire - raise TApplicationException(TApplicationException.MISSING_RESULT, "describe_schema_versions failed: unknown result"); - - def describe_keyspaces(self, ): - """ - list the defined keyspaces in this cluster - """ - self.send_describe_keyspaces() - return self.recv_describe_keyspaces() - - def send_describe_keyspaces(self, ): - self._oprot.writeMessageBegin('describe_keyspaces', TMessageType.CALL, self._seqid) - args = describe_keyspaces_args() - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_describe_keyspaces(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = describe_keyspaces_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.ire is not None: - raise result.ire - raise TApplicationException(TApplicationException.MISSING_RESULT, "describe_keyspaces failed: unknown result"); - - def describe_cluster_name(self, ): - """ - get the cluster name - """ - self.send_describe_cluster_name() - return self.recv_describe_cluster_name() - - def send_describe_cluster_name(self, ): - self._oprot.writeMessageBegin('describe_cluster_name', TMessageType.CALL, self._seqid) - args = describe_cluster_name_args() - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_describe_cluster_name(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = describe_cluster_name_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "describe_cluster_name failed: unknown result"); - - def describe_version(self, ): - """ - get the thrift api version - """ - self.send_describe_version() - return self.recv_describe_version() - - def send_describe_version(self, ): - self._oprot.writeMessageBegin('describe_version', TMessageType.CALL, self._seqid) - args = describe_version_args() - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_describe_version(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = describe_version_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "describe_version failed: unknown result"); - - def describe_ring(self, 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. - - Parameters: - - keyspace - """ - self.send_describe_ring(keyspace) - return self.recv_describe_ring() - - def send_describe_ring(self, keyspace): - self._oprot.writeMessageBegin('describe_ring', TMessageType.CALL, self._seqid) - args = describe_ring_args() - args.keyspace = keyspace - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_describe_ring(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = describe_ring_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.ire is not None: - raise result.ire - raise TApplicationException(TApplicationException.MISSING_RESULT, "describe_ring failed: unknown result"); - - def describe_local_ring(self, keyspace): - """ - same as describe_ring, but considers only nodes in the local DC - - Parameters: - - keyspace - """ - self.send_describe_local_ring(keyspace) - return self.recv_describe_local_ring() - - def send_describe_local_ring(self, keyspace): - self._oprot.writeMessageBegin('describe_local_ring', TMessageType.CALL, self._seqid) - args = describe_local_ring_args() - args.keyspace = keyspace - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_describe_local_ring(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = describe_local_ring_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.ire is not None: - raise result.ire - raise TApplicationException(TApplicationException.MISSING_RESULT, "describe_local_ring failed: unknown result"); - - def describe_token_map(self, ): - """ - get the mapping between token->node ip - without taking replication into consideration - https://issues.apache.org/jira/browse/CASSANDRA-4092 - """ - self.send_describe_token_map() - return self.recv_describe_token_map() - - def send_describe_token_map(self, ): - self._oprot.writeMessageBegin('describe_token_map', TMessageType.CALL, self._seqid) - args = describe_token_map_args() - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_describe_token_map(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = describe_token_map_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.ire is not None: - raise result.ire - raise TApplicationException(TApplicationException.MISSING_RESULT, "describe_token_map failed: unknown result"); - - def describe_partitioner(self, ): - """ - returns the partitioner used by this cluster - """ - self.send_describe_partitioner() - return self.recv_describe_partitioner() - - def send_describe_partitioner(self, ): - self._oprot.writeMessageBegin('describe_partitioner', TMessageType.CALL, self._seqid) - args = describe_partitioner_args() - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_describe_partitioner(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = describe_partitioner_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "describe_partitioner failed: unknown result"); - - def describe_snitch(self, ): - """ - returns the snitch used by this cluster - """ - self.send_describe_snitch() - return self.recv_describe_snitch() - - def send_describe_snitch(self, ): - self._oprot.writeMessageBegin('describe_snitch', TMessageType.CALL, self._seqid) - args = describe_snitch_args() - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_describe_snitch(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = describe_snitch_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "describe_snitch failed: unknown result"); - - def describe_keyspace(self, keyspace): - """ - describe specified keyspace - - Parameters: - - keyspace - """ - self.send_describe_keyspace(keyspace) - return self.recv_describe_keyspace() - - def send_describe_keyspace(self, keyspace): - self._oprot.writeMessageBegin('describe_keyspace', TMessageType.CALL, self._seqid) - args = describe_keyspace_args() - args.keyspace = keyspace - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_describe_keyspace(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = describe_keyspace_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.nfe is not None: - raise result.nfe - if result.ire is not None: - raise result.ire - raise TApplicationException(TApplicationException.MISSING_RESULT, "describe_keyspace failed: unknown result"); - - def describe_splits(self, cfName, start_token, end_token, keys_per_split): - """ - experimental API for hadoop/parallel query support. - may change violently and without warning. - - returns list of token strings such that first subrange is (list[0], list[1]], - next is (list[1], list[2]], etc. - - Parameters: - - cfName - - start_token - - end_token - - keys_per_split - """ - self.send_describe_splits(cfName, start_token, end_token, keys_per_split) - return self.recv_describe_splits() - - def send_describe_splits(self, cfName, start_token, end_token, keys_per_split): - self._oprot.writeMessageBegin('describe_splits', TMessageType.CALL, self._seqid) - args = describe_splits_args() - args.cfName = cfName - args.start_token = start_token - args.end_token = end_token - args.keys_per_split = keys_per_split - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_describe_splits(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = describe_splits_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.ire is not None: - raise result.ire - raise TApplicationException(TApplicationException.MISSING_RESULT, "describe_splits failed: unknown result"); - - def trace_next_query(self, ): - """ - Enables tracing for the next query in this connection and returns the UUID for that trace session - The next query will be traced idependently of trace probability and the returned UUID can be used to query the trace keyspace - """ - self.send_trace_next_query() - return self.recv_trace_next_query() - - def send_trace_next_query(self, ): - self._oprot.writeMessageBegin('trace_next_query', TMessageType.CALL, self._seqid) - args = trace_next_query_args() - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_trace_next_query(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = trace_next_query_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "trace_next_query failed: unknown result"); - - def describe_splits_ex(self, cfName, start_token, end_token, keys_per_split): - """ - Parameters: - - cfName - - start_token - - end_token - - keys_per_split - """ - self.send_describe_splits_ex(cfName, start_token, end_token, keys_per_split) - return self.recv_describe_splits_ex() - - def send_describe_splits_ex(self, cfName, start_token, end_token, keys_per_split): - self._oprot.writeMessageBegin('describe_splits_ex', TMessageType.CALL, self._seqid) - args = describe_splits_ex_args() - args.cfName = cfName - args.start_token = start_token - args.end_token = end_token - args.keys_per_split = keys_per_split - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_describe_splits_ex(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = describe_splits_ex_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.ire is not None: - raise result.ire - raise TApplicationException(TApplicationException.MISSING_RESULT, "describe_splits_ex failed: unknown result"); - - def system_add_column_family(self, cf_def): - """ - adds a column family. returns the new schema id. - - Parameters: - - cf_def - """ - self.send_system_add_column_family(cf_def) - return self.recv_system_add_column_family() - - def send_system_add_column_family(self, cf_def): - self._oprot.writeMessageBegin('system_add_column_family', TMessageType.CALL, self._seqid) - args = system_add_column_family_args() - args.cf_def = cf_def - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_system_add_column_family(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = system_add_column_family_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.ire is not None: - raise result.ire - if result.sde is not None: - raise result.sde - raise TApplicationException(TApplicationException.MISSING_RESULT, "system_add_column_family failed: unknown result"); - - def system_drop_column_family(self, column_family): - """ - drops a column family. returns the new schema id. - - Parameters: - - column_family - """ - self.send_system_drop_column_family(column_family) - return self.recv_system_drop_column_family() - - def send_system_drop_column_family(self, column_family): - self._oprot.writeMessageBegin('system_drop_column_family', TMessageType.CALL, self._seqid) - args = system_drop_column_family_args() - args.column_family = column_family - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_system_drop_column_family(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = system_drop_column_family_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.ire is not None: - raise result.ire - if result.sde is not None: - raise result.sde - raise TApplicationException(TApplicationException.MISSING_RESULT, "system_drop_column_family failed: unknown result"); - - def system_add_keyspace(self, ks_def): - """ - adds a keyspace and any column families that are part of it. returns the new schema id. - - Parameters: - - ks_def - """ - self.send_system_add_keyspace(ks_def) - return self.recv_system_add_keyspace() - - def send_system_add_keyspace(self, ks_def): - self._oprot.writeMessageBegin('system_add_keyspace', TMessageType.CALL, self._seqid) - args = system_add_keyspace_args() - args.ks_def = ks_def - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_system_add_keyspace(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = system_add_keyspace_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.ire is not None: - raise result.ire - if result.sde is not None: - raise result.sde - raise TApplicationException(TApplicationException.MISSING_RESULT, "system_add_keyspace failed: unknown result"); - - def system_drop_keyspace(self, keyspace): - """ - drops a keyspace and any column families that are part of it. returns the new schema id. - - Parameters: - - keyspace - """ - self.send_system_drop_keyspace(keyspace) - return self.recv_system_drop_keyspace() - - def send_system_drop_keyspace(self, keyspace): - self._oprot.writeMessageBegin('system_drop_keyspace', TMessageType.CALL, self._seqid) - args = system_drop_keyspace_args() - args.keyspace = keyspace - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_system_drop_keyspace(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = system_drop_keyspace_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.ire is not None: - raise result.ire - if result.sde is not None: - raise result.sde - raise TApplicationException(TApplicationException.MISSING_RESULT, "system_drop_keyspace failed: unknown result"); - - def system_update_keyspace(self, ks_def): - """ - updates properties of a keyspace. returns the new schema id. - - Parameters: - - ks_def - """ - self.send_system_update_keyspace(ks_def) - return self.recv_system_update_keyspace() - - def send_system_update_keyspace(self, ks_def): - self._oprot.writeMessageBegin('system_update_keyspace', TMessageType.CALL, self._seqid) - args = system_update_keyspace_args() - args.ks_def = ks_def - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_system_update_keyspace(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = system_update_keyspace_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.ire is not None: - raise result.ire - if result.sde is not None: - raise result.sde - raise TApplicationException(TApplicationException.MISSING_RESULT, "system_update_keyspace failed: unknown result"); - - def system_update_column_family(self, cf_def): - """ - updates properties of a column family. returns the new schema id. - - Parameters: - - cf_def - """ - self.send_system_update_column_family(cf_def) - return self.recv_system_update_column_family() - - def send_system_update_column_family(self, cf_def): - self._oprot.writeMessageBegin('system_update_column_family', TMessageType.CALL, self._seqid) - args = system_update_column_family_args() - args.cf_def = cf_def - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_system_update_column_family(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = system_update_column_family_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.ire is not None: - raise result.ire - if result.sde is not None: - raise result.sde - raise TApplicationException(TApplicationException.MISSING_RESULT, "system_update_column_family failed: unknown result"); - - def execute_cql_query(self, query, compression): - """ - @deprecated Throws InvalidRequestException since 2.2. Please use the CQL3 version instead. - - Parameters: - - query - - compression - """ - self.send_execute_cql_query(query, compression) - return self.recv_execute_cql_query() - - def send_execute_cql_query(self, query, compression): - self._oprot.writeMessageBegin('execute_cql_query', TMessageType.CALL, self._seqid) - args = execute_cql_query_args() - args.query = query - args.compression = compression - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_execute_cql_query(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = execute_cql_query_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.ire is not None: - raise result.ire - if result.ue is not None: - raise result.ue - if result.te is not None: - raise result.te - if result.sde is not None: - raise result.sde - raise TApplicationException(TApplicationException.MISSING_RESULT, "execute_cql_query failed: unknown result"); - - def execute_cql3_query(self, query, compression, consistency): - """ - Executes a CQL3 (Cassandra Query Language) statement and returns a - CqlResult containing the results. - - Parameters: - - query - - compression - - consistency - """ - self.send_execute_cql3_query(query, compression, consistency) - return self.recv_execute_cql3_query() - - def send_execute_cql3_query(self, query, compression, consistency): - self._oprot.writeMessageBegin('execute_cql3_query', TMessageType.CALL, self._seqid) - args = execute_cql3_query_args() - args.query = query - args.compression = compression - args.consistency = consistency - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_execute_cql3_query(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = execute_cql3_query_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.ire is not None: - raise result.ire - if result.ue is not None: - raise result.ue - if result.te is not None: - raise result.te - if result.sde is not None: - raise result.sde - raise TApplicationException(TApplicationException.MISSING_RESULT, "execute_cql3_query failed: unknown result"); - - def prepare_cql_query(self, query, compression): - """ - @deprecated Throws InvalidRequestException since 2.2. Please use the CQL3 version instead. - - Parameters: - - query - - compression - """ - self.send_prepare_cql_query(query, compression) - return self.recv_prepare_cql_query() - - def send_prepare_cql_query(self, query, compression): - self._oprot.writeMessageBegin('prepare_cql_query', TMessageType.CALL, self._seqid) - args = prepare_cql_query_args() - args.query = query - args.compression = compression - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_prepare_cql_query(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = prepare_cql_query_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.ire is not None: - raise result.ire - raise TApplicationException(TApplicationException.MISSING_RESULT, "prepare_cql_query failed: unknown result"); - - def prepare_cql3_query(self, query, compression): - """ - Prepare a CQL3 (Cassandra Query Language) statement by compiling and returning - - the type of CQL statement - - an id token of the compiled CQL stored on the server side. - - a count of the discovered bound markers in the statement - - Parameters: - - query - - compression - """ - self.send_prepare_cql3_query(query, compression) - return self.recv_prepare_cql3_query() - - def send_prepare_cql3_query(self, query, compression): - self._oprot.writeMessageBegin('prepare_cql3_query', TMessageType.CALL, self._seqid) - args = prepare_cql3_query_args() - args.query = query - args.compression = compression - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_prepare_cql3_query(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = prepare_cql3_query_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.ire is not None: - raise result.ire - raise TApplicationException(TApplicationException.MISSING_RESULT, "prepare_cql3_query failed: unknown result"); - - def execute_prepared_cql_query(self, itemId, values): - """ - @deprecated Throws InvalidRequestException since 2.2. Please use the CQL3 version instead. - - Parameters: - - itemId - - values - """ - self.send_execute_prepared_cql_query(itemId, values) - return self.recv_execute_prepared_cql_query() - - def send_execute_prepared_cql_query(self, itemId, values): - self._oprot.writeMessageBegin('execute_prepared_cql_query', TMessageType.CALL, self._seqid) - args = execute_prepared_cql_query_args() - args.itemId = itemId - args.values = values - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_execute_prepared_cql_query(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = execute_prepared_cql_query_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.ire is not None: - raise result.ire - if result.ue is not None: - raise result.ue - if result.te is not None: - raise result.te - if result.sde is not None: - raise result.sde - raise TApplicationException(TApplicationException.MISSING_RESULT, "execute_prepared_cql_query failed: unknown result"); - - def execute_prepared_cql3_query(self, itemId, values, consistency): - """ - Executes a prepared CQL3 (Cassandra Query Language) statement by passing an id token, a list of variables - to bind, and the consistency level, and returns a CqlResult containing the results. - - Parameters: - - itemId - - values - - consistency - """ - self.send_execute_prepared_cql3_query(itemId, values, consistency) - return self.recv_execute_prepared_cql3_query() - - def send_execute_prepared_cql3_query(self, itemId, values, consistency): - self._oprot.writeMessageBegin('execute_prepared_cql3_query', TMessageType.CALL, self._seqid) - args = execute_prepared_cql3_query_args() - args.itemId = itemId - args.values = values - args.consistency = consistency - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_execute_prepared_cql3_query(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = execute_prepared_cql3_query_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.ire is not None: - raise result.ire - if result.ue is not None: - raise result.ue - if result.te is not None: - raise result.te - if result.sde is not None: - raise result.sde - raise TApplicationException(TApplicationException.MISSING_RESULT, "execute_prepared_cql3_query failed: unknown result"); - - def set_cql_version(self, version): - """ - @deprecated This is now a no-op. Please use the CQL3 specific methods instead. - - Parameters: - - version - """ - self.send_set_cql_version(version) - self.recv_set_cql_version() - - def send_set_cql_version(self, version): - self._oprot.writeMessageBegin('set_cql_version', TMessageType.CALL, self._seqid) - args = set_cql_version_args() - args.version = version - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_set_cql_version(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = set_cql_version_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.ire is not None: - raise result.ire - return - - -class Processor(Iface, TProcessor): - def __init__(self, handler): - self._handler = handler - self._processMap = {} - self._processMap["login"] = Processor.process_login - self._processMap["set_keyspace"] = Processor.process_set_keyspace - self._processMap["get"] = Processor.process_get - self._processMap["get_slice"] = Processor.process_get_slice - self._processMap["get_count"] = Processor.process_get_count - self._processMap["multiget_slice"] = Processor.process_multiget_slice - self._processMap["multiget_count"] = Processor.process_multiget_count - self._processMap["get_range_slices"] = Processor.process_get_range_slices - self._processMap["get_paged_slice"] = Processor.process_get_paged_slice - self._processMap["get_indexed_slices"] = Processor.process_get_indexed_slices - self._processMap["insert"] = Processor.process_insert - self._processMap["add"] = Processor.process_add - self._processMap["cas"] = Processor.process_cas - self._processMap["remove"] = Processor.process_remove - self._processMap["remove_counter"] = Processor.process_remove_counter - self._processMap["batch_mutate"] = Processor.process_batch_mutate - self._processMap["atomic_batch_mutate"] = Processor.process_atomic_batch_mutate - self._processMap["truncate"] = Processor.process_truncate - self._processMap["get_multi_slice"] = Processor.process_get_multi_slice - self._processMap["describe_schema_versions"] = Processor.process_describe_schema_versions - self._processMap["describe_keyspaces"] = Processor.process_describe_keyspaces - self._processMap["describe_cluster_name"] = Processor.process_describe_cluster_name - self._processMap["describe_version"] = Processor.process_describe_version - self._processMap["describe_ring"] = Processor.process_describe_ring - self._processMap["describe_local_ring"] = Processor.process_describe_local_ring - self._processMap["describe_token_map"] = Processor.process_describe_token_map - self._processMap["describe_partitioner"] = Processor.process_describe_partitioner - self._processMap["describe_snitch"] = Processor.process_describe_snitch - self._processMap["describe_keyspace"] = Processor.process_describe_keyspace - self._processMap["describe_splits"] = Processor.process_describe_splits - self._processMap["trace_next_query"] = Processor.process_trace_next_query - self._processMap["describe_splits_ex"] = Processor.process_describe_splits_ex - self._processMap["system_add_column_family"] = Processor.process_system_add_column_family - self._processMap["system_drop_column_family"] = Processor.process_system_drop_column_family - self._processMap["system_add_keyspace"] = Processor.process_system_add_keyspace - self._processMap["system_drop_keyspace"] = Processor.process_system_drop_keyspace - self._processMap["system_update_keyspace"] = Processor.process_system_update_keyspace - self._processMap["system_update_column_family"] = Processor.process_system_update_column_family - self._processMap["execute_cql_query"] = Processor.process_execute_cql_query - self._processMap["execute_cql3_query"] = Processor.process_execute_cql3_query - self._processMap["prepare_cql_query"] = Processor.process_prepare_cql_query - self._processMap["prepare_cql3_query"] = Processor.process_prepare_cql3_query - self._processMap["execute_prepared_cql_query"] = Processor.process_execute_prepared_cql_query - self._processMap["execute_prepared_cql3_query"] = Processor.process_execute_prepared_cql3_query - self._processMap["set_cql_version"] = Processor.process_set_cql_version - - def process(self, iprot, oprot): - (name, type, seqid) = iprot.readMessageBegin() - if name not in self._processMap: - iprot.skip(TType.STRUCT) - iprot.readMessageEnd() - x = TApplicationException(TApplicationException.UNKNOWN_METHOD, 'Unknown function %s' % (name)) - oprot.writeMessageBegin(name, TMessageType.EXCEPTION, seqid) - x.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - return - else: - self._processMap[name](self, seqid, iprot, oprot) - return True - - def process_login(self, seqid, iprot, oprot): - args = login_args() - args.read(iprot) - iprot.readMessageEnd() - result = login_result() - try: - self._handler.login(args.auth_request) - except AuthenticationException as authnx: - result.authnx = authnx - except AuthorizationException as authzx: - result.authzx = authzx - oprot.writeMessageBegin("login", TMessageType.REPLY, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_set_keyspace(self, seqid, iprot, oprot): - args = set_keyspace_args() - args.read(iprot) - iprot.readMessageEnd() - result = set_keyspace_result() - try: - self._handler.set_keyspace(args.keyspace) - except InvalidRequestException as ire: - result.ire = ire - oprot.writeMessageBegin("set_keyspace", TMessageType.REPLY, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_get(self, seqid, iprot, oprot): - args = get_args() - args.read(iprot) - iprot.readMessageEnd() - result = get_result() - try: - result.success = self._handler.get(args.key, args.column_path, args.consistency_level) - except InvalidRequestException as ire: - result.ire = ire - except NotFoundException as nfe: - result.nfe = nfe - except UnavailableException as ue: - result.ue = ue - except TimedOutException as te: - result.te = te - oprot.writeMessageBegin("get", TMessageType.REPLY, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_get_slice(self, seqid, iprot, oprot): - args = get_slice_args() - args.read(iprot) - iprot.readMessageEnd() - result = get_slice_result() - try: - result.success = self._handler.get_slice(args.key, args.column_parent, args.predicate, args.consistency_level) - except InvalidRequestException as ire: - result.ire = ire - except UnavailableException as ue: - result.ue = ue - except TimedOutException as te: - result.te = te - oprot.writeMessageBegin("get_slice", TMessageType.REPLY, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_get_count(self, seqid, iprot, oprot): - args = get_count_args() - args.read(iprot) - iprot.readMessageEnd() - result = get_count_result() - try: - result.success = self._handler.get_count(args.key, args.column_parent, args.predicate, args.consistency_level) - except InvalidRequestException as ire: - result.ire = ire - except UnavailableException as ue: - result.ue = ue - except TimedOutException as te: - result.te = te - oprot.writeMessageBegin("get_count", TMessageType.REPLY, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_multiget_slice(self, seqid, iprot, oprot): - args = multiget_slice_args() - args.read(iprot) - iprot.readMessageEnd() - result = multiget_slice_result() - try: - result.success = self._handler.multiget_slice(args.keys, args.column_parent, args.predicate, args.consistency_level) - except InvalidRequestException as ire: - result.ire = ire - except UnavailableException as ue: - result.ue = ue - except TimedOutException as te: - result.te = te - oprot.writeMessageBegin("multiget_slice", TMessageType.REPLY, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_multiget_count(self, seqid, iprot, oprot): - args = multiget_count_args() - args.read(iprot) - iprot.readMessageEnd() - result = multiget_count_result() - try: - result.success = self._handler.multiget_count(args.keys, args.column_parent, args.predicate, args.consistency_level) - except InvalidRequestException as ire: - result.ire = ire - except UnavailableException as ue: - result.ue = ue - except TimedOutException as te: - result.te = te - oprot.writeMessageBegin("multiget_count", TMessageType.REPLY, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_get_range_slices(self, seqid, iprot, oprot): - args = get_range_slices_args() - args.read(iprot) - iprot.readMessageEnd() - result = get_range_slices_result() - try: - result.success = self._handler.get_range_slices(args.column_parent, args.predicate, args.range, args.consistency_level) - except InvalidRequestException as ire: - result.ire = ire - except UnavailableException as ue: - result.ue = ue - except TimedOutException as te: - result.te = te - oprot.writeMessageBegin("get_range_slices", TMessageType.REPLY, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_get_paged_slice(self, seqid, iprot, oprot): - args = get_paged_slice_args() - args.read(iprot) - iprot.readMessageEnd() - result = get_paged_slice_result() - try: - result.success = self._handler.get_paged_slice(args.column_family, args.range, args.start_column, args.consistency_level) - except InvalidRequestException as ire: - result.ire = ire - except UnavailableException as ue: - result.ue = ue - except TimedOutException as te: - result.te = te - oprot.writeMessageBegin("get_paged_slice", TMessageType.REPLY, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_get_indexed_slices(self, seqid, iprot, oprot): - args = get_indexed_slices_args() - args.read(iprot) - iprot.readMessageEnd() - result = get_indexed_slices_result() - try: - result.success = self._handler.get_indexed_slices(args.column_parent, args.index_clause, args.column_predicate, args.consistency_level) - except InvalidRequestException as ire: - result.ire = ire - except UnavailableException as ue: - result.ue = ue - except TimedOutException as te: - result.te = te - oprot.writeMessageBegin("get_indexed_slices", TMessageType.REPLY, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_insert(self, seqid, iprot, oprot): - args = insert_args() - args.read(iprot) - iprot.readMessageEnd() - result = insert_result() - try: - self._handler.insert(args.key, args.column_parent, args.column, args.consistency_level) - except InvalidRequestException as ire: - result.ire = ire - except UnavailableException as ue: - result.ue = ue - except TimedOutException as te: - result.te = te - oprot.writeMessageBegin("insert", TMessageType.REPLY, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_add(self, seqid, iprot, oprot): - args = add_args() - args.read(iprot) - iprot.readMessageEnd() - result = add_result() - try: - self._handler.add(args.key, args.column_parent, args.column, args.consistency_level) - except InvalidRequestException as ire: - result.ire = ire - except UnavailableException as ue: - result.ue = ue - except TimedOutException as te: - result.te = te - oprot.writeMessageBegin("add", TMessageType.REPLY, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_cas(self, seqid, iprot, oprot): - args = cas_args() - args.read(iprot) - iprot.readMessageEnd() - result = cas_result() - try: - result.success = self._handler.cas(args.key, args.column_family, args.expected, args.updates, args.serial_consistency_level, args.commit_consistency_level) - except InvalidRequestException as ire: - result.ire = ire - except UnavailableException as ue: - result.ue = ue - except TimedOutException as te: - result.te = te - oprot.writeMessageBegin("cas", TMessageType.REPLY, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_remove(self, seqid, iprot, oprot): - args = remove_args() - args.read(iprot) - iprot.readMessageEnd() - result = remove_result() - try: - self._handler.remove(args.key, args.column_path, args.timestamp, args.consistency_level) - except InvalidRequestException as ire: - result.ire = ire - except UnavailableException as ue: - result.ue = ue - except TimedOutException as te: - result.te = te - oprot.writeMessageBegin("remove", TMessageType.REPLY, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_remove_counter(self, seqid, iprot, oprot): - args = remove_counter_args() - args.read(iprot) - iprot.readMessageEnd() - result = remove_counter_result() - try: - self._handler.remove_counter(args.key, args.path, args.consistency_level) - except InvalidRequestException as ire: - result.ire = ire - except UnavailableException as ue: - result.ue = ue - except TimedOutException as te: - result.te = te - oprot.writeMessageBegin("remove_counter", TMessageType.REPLY, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_batch_mutate(self, seqid, iprot, oprot): - args = batch_mutate_args() - args.read(iprot) - iprot.readMessageEnd() - result = batch_mutate_result() - try: - self._handler.batch_mutate(args.mutation_map, args.consistency_level) - except InvalidRequestException as ire: - result.ire = ire - except UnavailableException as ue: - result.ue = ue - except TimedOutException as te: - result.te = te - oprot.writeMessageBegin("batch_mutate", TMessageType.REPLY, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_atomic_batch_mutate(self, seqid, iprot, oprot): - args = atomic_batch_mutate_args() - args.read(iprot) - iprot.readMessageEnd() - result = atomic_batch_mutate_result() - try: - self._handler.atomic_batch_mutate(args.mutation_map, args.consistency_level) - except InvalidRequestException as ire: - result.ire = ire - except UnavailableException as ue: - result.ue = ue - ex
<TRUNCATED> http://git-wip-us.apache.org/repos/asf/cassandra-dtest/blob/49b2dda4/thrift_bindings/v22/__init__.py ---------------------------------------------------------------------- diff --git a/thrift_bindings/v22/__init__.py b/thrift_bindings/v22/__init__.py deleted file mode 100644 index 2132df0..0000000 --- a/thrift_bindings/v22/__init__.py +++ /dev/null @@ -1 +0,0 @@ -__all__ = ['ttypes', 'constants', 'Cassandra'] --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org
