cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aweisb...@apache.org
Subject [12/36] cassandra-dtest git commit: Migrate dtests to use pytest and python3
Date Mon, 29 Jan 2018 21:10:15 GMT
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-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org


Mime
View raw message