<s> from thrift . Thrift import * <EOL> from thrift . transport import TTransport <EOL> from thrift . protocol import TBinaryProtocol , TProtocol <EOL> try : <EOL> from thrift . protocol import fastbinary <EOL> except : <EOL> fastbinary = None <EOL> class ConsistencyLevel : <EOL> """<STR_LIT>""" <EOL> ONE = <NUM_LIT:1> <EOL> QUORUM = <NUM_LIT:2> <EOL> LOCAL_QUORUM = <NUM_LIT:3> <EOL> EACH_QUORUM = <NUM_LIT:4> <EOL> ALL = <NUM_LIT:5> <EOL> ANY = <NUM_LIT:6> <EOL> TWO = <NUM_LIT:7> <EOL> THREE = <NUM_LIT:8> <EOL> _VALUES_TO_NAMES = { <EOL> <NUM_LIT:1> : "<STR_LIT>" , <EOL> <NUM_LIT:2> : "<STR_LIT>" , <EOL> <NUM_LIT:3> : "<STR_LIT>" , <EOL> <NUM_LIT:4> : "<STR_LIT>" , <EOL> <NUM_LIT:5> : "<STR_LIT>" , <EOL> <NUM_LIT:6> : "<STR_LIT>" , <EOL> <NUM_LIT:7> : "<STR_LIT>" , <EOL> <NUM_LIT:8> : "<STR_LIT>" , <EOL> } <EOL> _NAMES_TO_VALUES = { <EOL> "<STR_LIT>" : <NUM_LIT:1> , <EOL> "<STR_LIT>" : <NUM_LIT:2> , <EOL> "<STR_LIT>" : <NUM_LIT:3> , <EOL> "<STR_LIT>" : <NUM_LIT:4> , <EOL> "<STR_LIT>" : <NUM_LIT:5> , <EOL> "<STR_LIT>" : <NUM_LIT:6> , <EOL> "<STR_LIT>" : <NUM_LIT:7> , <EOL> "<STR_LIT>" : <NUM_LIT:8> , <EOL> } <EOL> class IndexOperator : <EOL> EQ = <NUM_LIT:0> <EOL> GTE = <NUM_LIT:1> <EOL> GT = <NUM_LIT:2> <EOL> LTE = <NUM_LIT:3> <EOL> LT = <NUM_LIT:4> <EOL> _VALUES_TO_NAMES = { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> <NUM_LIT:1> : "<STR_LIT>" , <EOL> <NUM_LIT:2> : "<STR_LIT>" , <EOL> <NUM_LIT:3> : "<STR_LIT>" , <EOL> <NUM_LIT:4> : "<STR_LIT>" , <EOL> } <EOL> _NAMES_TO_VALUES = { <EOL> "<STR_LIT>" : <NUM_LIT:0> , <EOL> "<STR_LIT>" : <NUM_LIT:1> , <EOL> "<STR_LIT>" : <NUM_LIT:2> , <EOL> "<STR_LIT>" : <NUM_LIT:3> , <EOL> "<STR_LIT>" : <NUM_LIT:4> , <EOL> } <EOL> class IndexType : <EOL> KEYS = <NUM_LIT:0> <EOL> _VALUES_TO_NAMES = { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> } <EOL> _NAMES_TO_VALUES = { <EOL> "<STR_LIT>" : <NUM_LIT:0> , <EOL> } <EOL> class Column : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRING , '<STR_LIT:name>' , None , None , ) , <EOL> ( <NUM_LIT:2> , TType . STRING , '<STR_LIT:value>' , None , None , ) , <EOL> ( <NUM_LIT:3> , TType . I64 , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT:4> , TType . I32 , '<STR_LIT>' , None , None , ) , <EOL> ) <EOL> def __init__ ( self , name = None , value = None , timestamp = None , ttl = None , ) : <EOL> self . name = name <EOL> self . value = value <EOL> self . timestamp = timestamp <EOL> self . ttl = ttl <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> if fid == <NUM_LIT:1> : <EOL> if ftype == TType . STRING : <EOL> self . name = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:2> : <EOL> if ftype == TType . STRING : <EOL> self . value = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:3> : <EOL> if ftype == TType . I64 : <EOL> self . timestamp = iprot . readI64 ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:4> : <EOL> if ftype == TType . I32 : <EOL> self . ttl = iprot . readI32 ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> if self . name != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:name>' , TType . STRING , <NUM_LIT:1> ) <EOL> oprot . writeString ( self . name ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . value != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:value>' , TType . STRING , <NUM_LIT:2> ) <EOL> oprot . writeString ( self . value ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . timestamp != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . I64 , <NUM_LIT:3> ) <EOL> oprot . writeI64 ( self . timestamp ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . ttl != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . I32 , <NUM_LIT:4> ) <EOL> oprot . writeI32 ( self . ttl ) <EOL> oprot . writeFieldEnd ( ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> if self . name is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> if self . value is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> if self . timestamp is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> return <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) <EOL> class SuperColumn : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRING , '<STR_LIT:name>' , None , None , ) , <EOL> ( <NUM_LIT:2> , TType . LIST , '<STR_LIT>' , ( TType . STRUCT , ( Column , Column . thrift_spec ) ) , None , ) , <EOL> ) <EOL> def __init__ ( self , name = None , columns = None , ) : <EOL> self . name = name <EOL> self . columns = columns <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> if fid == <NUM_LIT:1> : <EOL> if ftype == TType . STRING : <EOL> self . name = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:2> : <EOL> if ftype == TType . LIST : <EOL> self . columns = [ ] <EOL> ( _etype3 , _size0 ) = iprot . readListBegin ( ) <EOL> for _i4 in xrange ( _size0 ) : <EOL> _elem5 = Column ( ) <EOL> _elem5 . read ( iprot ) <EOL> self . columns . append ( _elem5 ) <EOL> iprot . readListEnd ( ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> if self . name != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:name>' , TType . STRING , <NUM_LIT:1> ) <EOL> oprot . writeString ( self . name ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . columns != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . LIST , <NUM_LIT:2> ) <EOL> oprot . writeListBegin ( TType . STRUCT , len ( self . columns ) ) <EOL> for iter6 in self . columns : <EOL> iter6 . write ( oprot ) <EOL> oprot . writeListEnd ( ) <EOL> oprot . writeFieldEnd ( ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> if self . name is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> if self . columns is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> return <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) <EOL> class ColumnOrSuperColumn : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRUCT , '<STR_LIT>' , ( Column , Column . thrift_spec ) , None , ) , <EOL> ( <NUM_LIT:2> , TType . STRUCT , '<STR_LIT>' , ( SuperColumn , SuperColumn . thrift_spec ) , None , ) , <EOL> ) <EOL> def __init__ ( self , column = None , super_column = None , ) : <EOL> self . column = column <EOL> self . super_column = super_column <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> if fid == <NUM_LIT:1> : <EOL> if ftype == TType . STRUCT : <EOL> self . column = Column ( ) <EOL> self . column . read ( iprot ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:2> : <EOL> if ftype == TType . STRUCT : <EOL> self . super_column = SuperColumn ( ) <EOL> self . super_column . read ( iprot ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> if self . column != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRUCT , <NUM_LIT:1> ) <EOL> self . column . write ( oprot ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . super_column != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRUCT , <NUM_LIT:2> ) <EOL> self . super_column . write ( oprot ) <EOL> oprot . writeFieldEnd ( ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> return <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) <EOL> class NotFoundException ( Exception ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> ) <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> return <EOL> def __str__ ( self ) : <EOL> return repr ( self ) <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) <EOL> class InvalidRequestException ( Exception ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRING , '<STR_LIT>' , None , None , ) , <EOL> ) <EOL> def __init__ ( self , why = None , ) : <EOL> self . why = why <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> if fid == <NUM_LIT:1> : <EOL> if ftype == TType . STRING : <EOL> self . why = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> if self . why != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:1> ) <EOL> oprot . writeString ( self . why ) <EOL> oprot . writeFieldEnd ( ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> if self . why is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> return <EOL> def __str__ ( self ) : <EOL> return repr ( self ) <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) <EOL> class UnavailableException ( Exception ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> ) <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> return <EOL> def __str__ ( self ) : <EOL> return repr ( self ) <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) <EOL> class TimedOutException ( Exception ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> ) <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> return <EOL> def __str__ ( self ) : <EOL> return repr ( self ) <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) <EOL> class AuthenticationException ( Exception ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRING , '<STR_LIT>' , None , None , ) , <EOL> ) <EOL> def __init__ ( self , why = None , ) : <EOL> self . why = why <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> if fid == <NUM_LIT:1> : <EOL> if ftype == TType . STRING : <EOL> self . why = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> if self . why != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:1> ) <EOL> oprot . writeString ( self . why ) <EOL> oprot . writeFieldEnd ( ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> if self . why is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> return <EOL> def __str__ ( self ) : <EOL> return repr ( self ) <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) <EOL> class AuthorizationException ( Exception ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRING , '<STR_LIT>' , None , None , ) , <EOL> ) <EOL> def __init__ ( self , why = None , ) : <EOL> self . why = why <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> if fid == <NUM_LIT:1> : <EOL> if ftype == TType . STRING : <EOL> self . why = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> if self . why != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:1> ) <EOL> oprot . writeString ( self . why ) <EOL> oprot . writeFieldEnd ( ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> if self . why is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> return <EOL> def __str__ ( self ) : <EOL> return repr ( self ) <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) <EOL> class ColumnParent : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> None , <EOL> None , <EOL> ( <NUM_LIT:3> , TType . STRING , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT:4> , TType . STRING , '<STR_LIT>' , None , None , ) , <EOL> ) <EOL> def __init__ ( self , column_family = None , super_column = None , ) : <EOL> self . column_family = column_family <EOL> self . super_column = super_column <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> if fid == <NUM_LIT:3> : <EOL> if ftype == TType . STRING : <EOL> self . column_family = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:4> : <EOL> if ftype == TType . STRING : <EOL> self . super_column = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> if self . column_family != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:3> ) <EOL> oprot . writeString ( self . column_family ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . super_column != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:4> ) <EOL> oprot . writeString ( self . super_column ) <EOL> oprot . writeFieldEnd ( ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> if self . column_family is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> return <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) <EOL> class ColumnPath : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> None , <EOL> None , <EOL> ( <NUM_LIT:3> , TType . STRING , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT:4> , TType . STRING , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT:5> , TType . STRING , '<STR_LIT>' , None , None , ) , <EOL> ) <EOL> def __init__ ( self , column_family = None , super_column = None , column = None , ) : <EOL> self . column_family = column_family <EOL> self . super_column = super_column <EOL> self . column = column <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> if fid == <NUM_LIT:3> : <EOL> if ftype == TType . STRING : <EOL> self . column_family = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:4> : <EOL> if ftype == TType . STRING : <EOL> self . super_column = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:5> : <EOL> if ftype == TType . STRING : <EOL> self . column = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> if self . column_family != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:3> ) <EOL> oprot . writeString ( self . column_family ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . super_column != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:4> ) <EOL> oprot . writeString ( self . super_column ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . column != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:5> ) <EOL> oprot . writeString ( self . column ) <EOL> oprot . writeFieldEnd ( ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> if self . column_family is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> return <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) <EOL> class SliceRange : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRING , '<STR_LIT:start>' , None , None , ) , <EOL> ( <NUM_LIT:2> , TType . STRING , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT:3> , TType . BOOL , '<STR_LIT>' , None , False , ) , <EOL> ( <NUM_LIT:4> , TType . I32 , '<STR_LIT:count>' , None , <NUM_LIT:100> , ) , <EOL> ) <EOL> def __init__ ( self , start = None , finish = None , reversed = thrift_spec [ <NUM_LIT:3> ] [ <NUM_LIT:4> ] , count = thrift_spec [ <NUM_LIT:4> ] [ <NUM_LIT:4> ] , ) : <EOL> self . start = start <EOL> self . finish = finish <EOL> self . reversed = reversed <EOL> self . count = count <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> if fid == <NUM_LIT:1> : <EOL> if ftype == TType . STRING : <EOL> self . start = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:2> : <EOL> if ftype == TType . STRING : <EOL> self . finish = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:3> : <EOL> if ftype == TType . BOOL : <EOL> self . reversed = iprot . readBool ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:4> : <EOL> if ftype == TType . I32 : <EOL> self . count = iprot . readI32 ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> if self . start != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:start>' , TType . STRING , <NUM_LIT:1> ) <EOL> oprot . writeString ( self . start ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . finish != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:2> ) <EOL> oprot . writeString ( self . finish ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . reversed != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . BOOL , <NUM_LIT:3> ) <EOL> oprot . writeBool ( self . reversed ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . count != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:count>' , TType . I32 , <NUM_LIT:4> ) <EOL> oprot . writeI32 ( self . count ) <EOL> oprot . writeFieldEnd ( ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> if self . start is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> if self . finish is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> if self . reversed is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> if self . count is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> return <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) <EOL> class SlicePredicate : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . LIST , '<STR_LIT>' , ( TType . STRING , None ) , None , ) , <EOL> ( <NUM_LIT:2> , TType . STRUCT , '<STR_LIT>' , ( SliceRange , SliceRange . thrift_spec ) , None , ) , <EOL> ) <EOL> def __init__ ( self , column_names = None , slice_range = None , ) : <EOL> self . column_names = column_names <EOL> self . slice_range = slice_range <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> if fid == <NUM_LIT:1> : <EOL> if ftype == TType . LIST : <EOL> self . column_names = [ ] <EOL> ( _etype10 , _size7 ) = iprot . readListBegin ( ) <EOL> for _i11 in xrange ( _size7 ) : <EOL> _elem12 = iprot . readString ( ) ; <EOL> self . column_names . append ( _elem12 ) <EOL> iprot . readListEnd ( ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:2> : <EOL> if ftype == TType . STRUCT : <EOL> self . slice_range = SliceRange ( ) <EOL> self . slice_range . read ( iprot ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> if self . column_names != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . LIST , <NUM_LIT:1> ) <EOL> oprot . writeListBegin ( TType . STRING , len ( self . column_names ) ) <EOL> for iter13 in self . column_names : <EOL> oprot . writeString ( iter13 ) <EOL> oprot . writeListEnd ( ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . slice_range != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRUCT , <NUM_LIT:2> ) <EOL> self . slice_range . write ( oprot ) <EOL> oprot . writeFieldEnd ( ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> return <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) <EOL> class IndexExpression : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRING , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT:2> , TType . I32 , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT:3> , TType . STRING , '<STR_LIT:value>' , None , None , ) , <EOL> ) <EOL> def __init__ ( self , column_name = None , op = None , value = None , ) : <EOL> self . column_name = column_name <EOL> self . op = op <EOL> self . value = value <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> if fid == <NUM_LIT:1> : <EOL> if ftype == TType . STRING : <EOL> self . column_name = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:2> : <EOL> if ftype == TType . I32 : <EOL> self . op = iprot . readI32 ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:3> : <EOL> if ftype == TType . STRING : <EOL> self . value = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> if self . column_name != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:1> ) <EOL> oprot . writeString ( self . column_name ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . op != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . I32 , <NUM_LIT:2> ) <EOL> oprot . writeI32 ( self . op ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . value != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:value>' , TType . STRING , <NUM_LIT:3> ) <EOL> oprot . writeString ( self . value ) <EOL> oprot . writeFieldEnd ( ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> if self . column_name is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> if self . op is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> if self . value is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> return <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) <EOL> class IndexClause : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . LIST , '<STR_LIT>' , ( TType . STRUCT , ( IndexExpression , IndexExpression . thrift_spec ) ) , None , ) , <EOL> ( <NUM_LIT:2> , TType . STRING , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT:3> , TType . I32 , '<STR_LIT:count>' , None , <NUM_LIT:100> , ) , <EOL> ) <EOL> def __init__ ( self , expressions = None , start_key = None , count = thrift_spec [ <NUM_LIT:3> ] [ <NUM_LIT:4> ] , ) : <EOL> self . expressions = expressions <EOL> self . start_key = start_key <EOL> self . count = count <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> if fid == <NUM_LIT:1> : <EOL> if ftype == TType . LIST : <EOL> self . expressions = [ ] <EOL> ( _etype17 , _size14 ) = iprot . readListBegin ( ) <EOL> for _i18 in xrange ( _size14 ) : <EOL> _elem19 = IndexExpression ( ) <EOL> _elem19 . read ( iprot ) <EOL> self . expressions . append ( _elem19 ) <EOL> iprot . readListEnd ( ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:2> : <EOL> if ftype == TType . STRING : <EOL> self . start_key = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:3> : <EOL> if ftype == TType . I32 : <EOL> self . count = iprot . readI32 ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> if self . expressions != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . LIST , <NUM_LIT:1> ) <EOL> oprot . writeListBegin ( TType . STRUCT , len ( self . expressions ) ) <EOL> for iter20 in self . expressions : <EOL> iter20 . write ( oprot ) <EOL> oprot . writeListEnd ( ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . start_key != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:2> ) <EOL> oprot . writeString ( self . start_key ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . count != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:count>' , TType . I32 , <NUM_LIT:3> ) <EOL> oprot . writeI32 ( self . count ) <EOL> oprot . writeFieldEnd ( ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> if self . expressions is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> if self . start_key is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> if self . count is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> return <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) <EOL> class KeyRange : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRING , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT:2> , TType . STRING , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT:3> , TType . STRING , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT:4> , TType . STRING , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT:5> , TType . I32 , '<STR_LIT:count>' , None , <NUM_LIT:100> , ) , <EOL> ) <EOL> def __init__ ( self , start_key = None , end_key = None , start_token = None , end_token = None , count = thrift_spec [ <NUM_LIT:5> ] [ <NUM_LIT:4> ] , ) : <EOL> self . start_key = start_key <EOL> self . end_key = end_key <EOL> self . start_token = start_token <EOL> self . end_token = end_token <EOL> self . count = count <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> if fid == <NUM_LIT:1> : <EOL> if ftype == TType . STRING : <EOL> self . start_key = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:2> : <EOL> if ftype == TType . STRING : <EOL> self . end_key = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:3> : <EOL> if ftype == TType . STRING : <EOL> self . start_token = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:4> : <EOL> if ftype == TType . STRING : <EOL> self . end_token = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:5> : <EOL> if ftype == TType . I32 : <EOL> self . count = iprot . readI32 ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> if self . start_key != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:1> ) <EOL> oprot . writeString ( self . start_key ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . end_key != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:2> ) <EOL> oprot . writeString ( self . end_key ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . start_token != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:3> ) <EOL> oprot . writeString ( self . start_token ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . end_token != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:4> ) <EOL> oprot . writeString ( self . end_token ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . count != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:count>' , TType . I32 , <NUM_LIT:5> ) <EOL> oprot . writeI32 ( self . count ) <EOL> oprot . writeFieldEnd ( ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> if self . count is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> return <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) <EOL> class KeySlice : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRING , '<STR_LIT:key>' , None , None , ) , <EOL> ( <NUM_LIT:2> , TType . LIST , '<STR_LIT>' , ( TType . STRUCT , ( ColumnOrSuperColumn , ColumnOrSuperColumn . thrift_spec ) ) , None , ) , <EOL> ) <EOL> def __init__ ( self , key = None , columns = None , ) : <EOL> self . key = key <EOL> self . columns = columns <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> if fid == <NUM_LIT:1> : <EOL> if ftype == TType . STRING : <EOL> self . key = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:2> : <EOL> if ftype == TType . LIST : <EOL> self . columns = [ ] <EOL> ( _etype24 , _size21 ) = iprot . readListBegin ( ) <EOL> for _i25 in xrange ( _size21 ) : <EOL> _elem26 = ColumnOrSuperColumn ( ) <EOL> _elem26 . read ( iprot ) <EOL> self . columns . append ( _elem26 ) <EOL> iprot . readListEnd ( ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> if self . key != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:key>' , TType . STRING , <NUM_LIT:1> ) <EOL> oprot . writeString ( self . key ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . columns != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . LIST , <NUM_LIT:2> ) <EOL> oprot . writeListBegin ( TType . STRUCT , len ( self . columns ) ) <EOL> for iter27 in self . columns : <EOL> iter27 . write ( oprot ) <EOL> oprot . writeListEnd ( ) <EOL> oprot . writeFieldEnd ( ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> if self . key is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> if self . columns is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> return <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) <EOL> class KeyCount : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRING , '<STR_LIT:key>' , None , None , ) , <EOL> ( <NUM_LIT:2> , TType . I32 , '<STR_LIT:count>' , None , None , ) , <EOL> ) <EOL> def __init__ ( self , key = None , count = None , ) : <EOL> self . key = key <EOL> self . count = count <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> if fid == <NUM_LIT:1> : <EOL> if ftype == TType . STRING : <EOL> self . key = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:2> : <EOL> if ftype == TType . I32 : <EOL> self . count = iprot . readI32 ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> if self . key != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:key>' , TType . STRING , <NUM_LIT:1> ) <EOL> oprot . writeString ( self . key ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . count != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:count>' , TType . I32 , <NUM_LIT:2> ) <EOL> oprot . writeI32 ( self . count ) <EOL> oprot . writeFieldEnd ( ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> if self . key is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> if self . count is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> return <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) <EOL> class Deletion : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . I64 , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT:2> , TType . STRING , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT:3> , TType . STRUCT , '<STR_LIT>' , ( SlicePredicate , SlicePredicate . thrift_spec ) , None , ) , <EOL> ) <EOL> def __init__ ( self , timestamp = None , super_column = None , predicate = None , ) : <EOL> self . timestamp = timestamp <EOL> self . super_column = super_column <EOL> self . predicate = predicate <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> if fid == <NUM_LIT:1> : <EOL> if ftype == TType . I64 : <EOL> self . timestamp = iprot . readI64 ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:2> : <EOL> if ftype == TType . STRING : <EOL> self . super_column = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:3> : <EOL> if ftype == TType . STRUCT : <EOL> self . predicate = SlicePredicate ( ) <EOL> self . predicate . read ( iprot ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> if self . timestamp != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . I64 , <NUM_LIT:1> ) <EOL> oprot . writeI64 ( self . timestamp ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . super_column != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:2> ) <EOL> oprot . writeString ( self . super_column ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . predicate != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRUCT , <NUM_LIT:3> ) <EOL> self . predicate . write ( oprot ) <EOL> oprot . writeFieldEnd ( ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> if self . timestamp is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> return <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) <EOL> class Mutation : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRUCT , '<STR_LIT>' , ( ColumnOrSuperColumn , ColumnOrSuperColumn . thrift_spec ) , None , ) , <EOL> ( <NUM_LIT:2> , TType . STRUCT , '<STR_LIT>' , ( Deletion , Deletion . thrift_spec ) , None , ) , <EOL> ) <EOL> def __init__ ( self , column_or_supercolumn = None , deletion = None , ) : <EOL> self . column_or_supercolumn = column_or_supercolumn <EOL> self . deletion = deletion <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> if fid == <NUM_LIT:1> : <EOL> if ftype == TType . STRUCT : <EOL> self . column_or_supercolumn = ColumnOrSuperColumn ( ) <EOL> self . column_or_supercolumn . read ( iprot ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:2> : <EOL> if ftype == TType . STRUCT : <EOL> self . deletion = Deletion ( ) <EOL> self . deletion . read ( iprot ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> if self . column_or_supercolumn != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRUCT , <NUM_LIT:1> ) <EOL> self . column_or_supercolumn . write ( oprot ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . deletion != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRUCT , <NUM_LIT:2> ) <EOL> self . deletion . write ( oprot ) <EOL> oprot . writeFieldEnd ( ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> return <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) <EOL> class TokenRange : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRING , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT:2> , TType . STRING , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT:3> , TType . LIST , '<STR_LIT>' , ( TType . STRING , None ) , None , ) , <EOL> ) <EOL> def __init__ ( self , start_token = None , end_token = None , endpoints = None , ) : <EOL> self . start_token = start_token <EOL> self . end_token = end_token <EOL> self . endpoints = endpoints <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> if fid == <NUM_LIT:1> : <EOL> if ftype == TType . STRING : <EOL> self . start_token = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:2> : <EOL> if ftype == TType . STRING : <EOL> self . end_token = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:3> : <EOL> if ftype == TType . LIST : <EOL> self . endpoints = [ ] <EOL> ( _etype31 , _size28 ) = iprot . readListBegin ( ) <EOL> for _i32 in xrange ( _size28 ) : <EOL> _elem33 = iprot . readString ( ) ; <EOL> self . endpoints . append ( _elem33 ) <EOL> iprot . readListEnd ( ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> if self . start_token != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:1> ) <EOL> oprot . writeString ( self . start_token ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . end_token != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:2> ) <EOL> oprot . writeString ( self . end_token ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . endpoints != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . LIST , <NUM_LIT:3> ) <EOL> oprot . writeListBegin ( TType . STRING , len ( self . endpoints ) ) <EOL> for iter34 in self . endpoints : <EOL> oprot . writeString ( iter34 ) <EOL> oprot . writeListEnd ( ) <EOL> oprot . writeFieldEnd ( ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> if self . start_token is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> if self . end_token is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> if self . endpoints is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> return <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) <EOL> class AuthenticationRequest : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . MAP , '<STR_LIT>' , ( TType . STRING , None , TType . STRING , None ) , None , ) , <EOL> ) <EOL> def __init__ ( self , credentials = None , ) : <EOL> self . credentials = credentials <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> if fid == <NUM_LIT:1> : <EOL> if ftype == TType . MAP : <EOL> self . credentials = { } <EOL> ( _ktype36 , _vtype37 , _size35 ) = iprot . readMapBegin ( ) <EOL> for _i39 in xrange ( _size35 ) : <EOL> _key40 = iprot . readString ( ) ; <EOL> _val41 = iprot . readString ( ) ; <EOL> self . credentials [ _key40 ] = _val41 <EOL> iprot . readMapEnd ( ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> if self . credentials != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . MAP , <NUM_LIT:1> ) <EOL> oprot . writeMapBegin ( TType . STRING , TType . STRING , len ( self . credentials ) ) <EOL> for kiter42 , viter43 in self . credentials . items ( ) : <EOL> oprot . writeString ( kiter42 ) <EOL> oprot . writeString ( viter43 ) <EOL> oprot . writeMapEnd ( ) <EOL> oprot . writeFieldEnd ( ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> if self . credentials is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> return <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) <EOL> class ColumnDef : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRING , '<STR_LIT:name>' , None , None , ) , <EOL> ( <NUM_LIT:2> , TType . STRING , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT:3> , TType . I32 , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT:4> , TType . STRING , '<STR_LIT>' , None , None , ) , <EOL> ) <EOL> def __init__ ( self , name = None , validation_class = None , index_type = None , index_name = None , ) : <EOL> self . name = name <EOL> self . validation_class = validation_class <EOL> self . index_type = index_type <EOL> self . index_name = index_name <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> if fid == <NUM_LIT:1> : <EOL> if ftype == TType . STRING : <EOL> self . name = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:2> : <EOL> if ftype == TType . STRING : <EOL> self . validation_class = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:3> : <EOL> if ftype == TType . I32 : <EOL> self . index_type = iprot . readI32 ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:4> : <EOL> if ftype == TType . STRING : <EOL> self . index_name = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> if self . name != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:name>' , TType . STRING , <NUM_LIT:1> ) <EOL> oprot . writeString ( self . name ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . validation_class != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:2> ) <EOL> oprot . writeString ( self . validation_class ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . index_type != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . I32 , <NUM_LIT:3> ) <EOL> oprot . writeI32 ( self . index_type ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . index_name != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:4> ) <EOL> oprot . writeString ( self . index_name ) <EOL> oprot . writeFieldEnd ( ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> if self . name is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> if self . validation_class is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> return <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) <EOL> class CfDef : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRING , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT:2> , TType . STRING , '<STR_LIT:name>' , None , None , ) , <EOL> ( <NUM_LIT:3> , TType . STRING , '<STR_LIT>' , None , "<STR_LIT>" , ) , <EOL> None , <EOL> ( <NUM_LIT:5> , TType . STRING , '<STR_LIT>' , None , "<STR_LIT>" , ) , <EOL> ( <NUM_LIT:6> , TType . STRING , '<STR_LIT>' , None , None , ) , <EOL> None , <EOL> ( <NUM_LIT:8> , TType . STRING , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT:9> , TType . DOUBLE , '<STR_LIT>' , None , <NUM_LIT:0> , ) , <EOL> None , <EOL> ( <NUM_LIT:11> , TType . DOUBLE , '<STR_LIT>' , None , <NUM_LIT> , ) , <EOL> ( <NUM_LIT:12> , TType . DOUBLE , '<STR_LIT>' , None , <NUM_LIT:1> , ) , <EOL> ( <NUM_LIT> , TType . LIST , '<STR_LIT>' , ( TType . STRUCT , ( ColumnDef , ColumnDef . thrift_spec ) ) , None , ) , <EOL> ( <NUM_LIT> , TType . I32 , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT:15> , TType . STRING , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT:16> , TType . I32 , '<STR_LIT:id>' , None , None , ) , <EOL> ( <NUM_LIT> , TType . I32 , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT> , TType . I32 , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT> , TType . I32 , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT:20> , TType . I32 , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT> , TType . I32 , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT> , TType . I32 , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT> , TType . DOUBLE , '<STR_LIT>' , None , None , ) , <EOL> ) <EOL> def __init__ ( self , keyspace = None , name = None , column_type = thrift_spec [ <NUM_LIT:3> ] [ <NUM_LIT:4> ] , comparator_type = thrift_spec [ <NUM_LIT:5> ] [ <NUM_LIT:4> ] , subcomparator_type = None , comment = None , row_cache_size = thrift_spec [ <NUM_LIT:9> ] [ <NUM_LIT:4> ] , key_cache_size = thrift_spec [ <NUM_LIT:11> ] [ <NUM_LIT:4> ] , read_repair_chance = thrift_spec [ <NUM_LIT:12> ] [ <NUM_LIT:4> ] , column_metadata = None , gc_grace_seconds = None , default_validation_class = None , id = None , min_compaction_threshold = None , max_compaction_threshold = None , row_cache_save_period_in_seconds = None , key_cache_save_period_in_seconds = None , memtable_flush_after_mins = None , memtable_throughput_in_mb = None , memtable_operations_in_millions = None , ) : <EOL> self . keyspace = keyspace <EOL> self . name = name <EOL> self . column_type = column_type <EOL> self . comparator_type = comparator_type <EOL> self . subcomparator_type = subcomparator_type <EOL> self . comment = comment <EOL> self . row_cache_size = row_cache_size <EOL> self . key_cache_size = key_cache_size <EOL> self . read_repair_chance = read_repair_chance <EOL> self . column_metadata = column_metadata <EOL> self . gc_grace_seconds = gc_grace_seconds <EOL> self . default_validation_class = default_validation_class <EOL> self . id = id <EOL> self . min_compaction_threshold = min_compaction_threshold <EOL> self . max_compaction_threshold = max_compaction_threshold <EOL> self . row_cache_save_period_in_seconds = row_cache_save_period_in_seconds <EOL> self . key_cache_save_period_in_seconds = key_cache_save_period_in_seconds <EOL> self . memtable_flush_after_mins = memtable_flush_after_mins <EOL> self . memtable_throughput_in_mb = memtable_throughput_in_mb <EOL> self . memtable_operations_in_millions = memtable_operations_in_millions <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> if fid == <NUM_LIT:1> : <EOL> if ftype == TType . STRING : <EOL> self . keyspace = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:2> : <EOL> if ftype == TType . STRING : <EOL> self . name = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:3> : <EOL> if ftype == TType . STRING : <EOL> self . column_type = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:5> : <EOL> if ftype == TType . STRING : <EOL> self . comparator_type = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:6> : <EOL> if ftype == TType . STRING : <EOL> self . subcomparator_type = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:8> : <EOL> if ftype == TType . STRING : <EOL> self . comment = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:9> : <EOL> if ftype == TType . DOUBLE : <EOL> self . row_cache_size = iprot . readDouble ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:11> : <EOL> if ftype == TType . DOUBLE : <EOL> self . key_cache_size = iprot . readDouble ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:12> : <EOL> if ftype == TType . DOUBLE : <EOL> self . read_repair_chance = iprot . readDouble ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT> : <EOL> if ftype == TType . LIST : <EOL> self . column_metadata = [ ] <EOL> ( _etype47 , _size44 ) = iprot . readListBegin ( ) <EOL> for _i48 in xrange ( _size44 ) : <EOL> _elem49 = ColumnDef ( ) <EOL> _elem49 . read ( iprot ) <EOL> self . column_metadata . append ( _elem49 ) <EOL> iprot . readListEnd ( ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT> : <EOL> if ftype == TType . I32 : <EOL> self . gc_grace_seconds = iprot . readI32 ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:15> : <EOL> if ftype == TType . STRING : <EOL> self . default_validation_class = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:16> : <EOL> if ftype == TType . I32 : <EOL> self . id = iprot . readI32 ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT> : <EOL> if ftype == TType . I32 : <EOL> self . min_compaction_threshold = iprot . readI32 ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT> : <EOL> if ftype == TType . I32 : <EOL> self . max_compaction_threshold = iprot . readI32 ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT> : <EOL> if ftype == TType . I32 : <EOL> self . row_cache_save_period_in_seconds = iprot . readI32 ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:20> : <EOL> if ftype == TType . I32 : <EOL> self . key_cache_save_period_in_seconds = iprot . readI32 ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT> : <EOL> if ftype == TType . I32 : <EOL> self . memtable_flush_after_mins = iprot . readI32 ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT> : <EOL> if ftype == TType . I32 : <EOL> self . memtable_throughput_in_mb = iprot . readI32 ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT> : <EOL> if ftype == TType . DOUBLE : <EOL> self . memtable_operations_in_millions = iprot . readDouble ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> if self . keyspace != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:1> ) <EOL> oprot . writeString ( self . keyspace ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . name != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:name>' , TType . STRING , <NUM_LIT:2> ) <EOL> oprot . writeString ( self . name ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . column_type != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:3> ) <EOL> oprot . writeString ( self . column_type ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . comparator_type != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:5> ) <EOL> oprot . writeString ( self . comparator_type ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . subcomparator_type != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:6> ) <EOL> oprot . writeString ( self . subcomparator_type ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . comment != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:8> ) <EOL> oprot . writeString ( self . comment ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . row_cache_size != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . DOUBLE , <NUM_LIT:9> ) <EOL> oprot . writeDouble ( self . row_cache_size ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . key_cache_size != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . DOUBLE , <NUM_LIT:11> ) <EOL> oprot . writeDouble ( self . key_cache_size ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . read_repair_chance != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . DOUBLE , <NUM_LIT:12> ) <EOL> oprot . writeDouble ( self . read_repair_chance ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . column_metadata != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . LIST , <NUM_LIT> ) <EOL> oprot . writeListBegin ( TType . STRUCT , len ( self . column_metadata ) ) <EOL> for iter50 in self . column_metadata : <EOL> iter50 . write ( oprot ) <EOL> oprot . writeListEnd ( ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . gc_grace_seconds != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . I32 , <NUM_LIT> ) <EOL> oprot . writeI32 ( self . gc_grace_seconds ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . default_validation_class != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:15> ) <EOL> oprot . writeString ( self . default_validation_class ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . id != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:id>' , TType . I32 , <NUM_LIT:16> ) <EOL> oprot . writeI32 ( self . id ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . min_compaction_threshold != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . I32 , <NUM_LIT> ) <EOL> oprot . writeI32 ( self . min_compaction_threshold ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . max_compaction_threshold != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . I32 , <NUM_LIT> ) <EOL> oprot . writeI32 ( self . max_compaction_threshold ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . row_cache_save_period_in_seconds != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . I32 , <NUM_LIT> ) <EOL> oprot . writeI32 ( self . row_cache_save_period_in_seconds ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . key_cache_save_period_in_seconds != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . I32 , <NUM_LIT:20> ) <EOL> oprot . writeI32 ( self . key_cache_save_period_in_seconds ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . memtable_flush_after_mins != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . I32 , <NUM_LIT> ) <EOL> oprot . writeI32 ( self . memtable_flush_after_mins ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . memtable_throughput_in_mb != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . I32 , <NUM_LIT> ) <EOL> oprot . writeI32 ( self . memtable_throughput_in_mb ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . memtable_operations_in_millions != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . DOUBLE , <NUM_LIT> ) <EOL> oprot . writeDouble ( self . memtable_operations_in_millions ) <EOL> oprot . writeFieldEnd ( ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> if self . keyspace is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> if self . name is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> return <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) <EOL> class KsDef : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRING , '<STR_LIT:name>' , None , None , ) , <EOL> ( <NUM_LIT:2> , TType . STRING , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT:3> , TType . MAP , '<STR_LIT>' , ( TType . STRING , None , TType . STRING , None ) , None , ) , <EOL> ( <NUM_LIT:4> , TType . I32 , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT:5> , TType . LIST , '<STR_LIT>' , ( TType . STRUCT , ( CfDef , CfDef . thrift_spec ) ) , None , ) , <EOL> ) <EOL> def __init__ ( self , name = None , strategy_class = None , strategy_options = None , replication_factor = None , cf_defs = None , ) : <EOL> self . name = name <EOL> self . strategy_class = strategy_class <EOL> self . strategy_options = strategy_options <EOL> self . replication_factor = replication_factor <EOL> self . cf_defs = cf_defs <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> if fid == <NUM_LIT:1> : <EOL> if ftype == TType . STRING : <EOL> self . name = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:2> : <EOL> if ftype == TType . STRING : <EOL> self . strategy_class = iprot . readString ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:3> : <EOL> if ftype == TType . MAP : <EOL> self . strategy_options = { } <EOL> ( _ktype52 , _vtype53 , _size51 ) = iprot . readMapBegin ( ) <EOL> for _i55 in xrange ( _size51 ) : <EOL> _key56 = iprot . readString ( ) ; <EOL> _val57 = iprot . readString ( ) ; <EOL> self . strategy_options [ _key56 ] = _val57 <EOL> iprot . readMapEnd ( ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:4> : <EOL> if ftype == TType . I32 : <EOL> self . replication_factor = iprot . readI32 ( ) ; <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:5> : <EOL> if ftype == TType . LIST : <EOL> self . cf_defs = [ ] <EOL> ( _etype61 , _size58 ) = iprot . readListBegin ( ) <EOL> for _i62 in xrange ( _size58 ) : <EOL> _elem63 = CfDef ( ) <EOL> _elem63 . read ( iprot ) <EOL> self . cf_defs . append ( _elem63 ) <EOL> iprot . readListEnd ( ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> if self . name != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:name>' , TType . STRING , <NUM_LIT:1> ) <EOL> oprot . writeString ( self . name ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . strategy_class != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:2> ) <EOL> oprot . writeString ( self . strategy_class ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . strategy_options != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . MAP , <NUM_LIT:3> ) <EOL> oprot . writeMapBegin ( TType . STRING , TType . STRING , len ( self . strategy_options ) ) <EOL> for kiter64 , viter65 in self . strategy_options . items ( ) : <EOL> oprot . writeString ( kiter64 ) <EOL> oprot . writeString ( viter65 ) <EOL> oprot . writeMapEnd ( ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . replication_factor != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . I32 , <NUM_LIT:4> ) <EOL> oprot . writeI32 ( self . replication_factor ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . cf_defs != None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . LIST , <NUM_LIT:5> ) <EOL> oprot . writeListBegin ( TType . STRUCT , len ( self . cf_defs ) ) <EOL> for iter66 in self . cf_defs : <EOL> iter66 . write ( oprot ) <EOL> oprot . writeListEnd ( ) <EOL> oprot . writeFieldEnd ( ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> if self . name is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> if self . strategy_class is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> if self . replication_factor is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> if self . cf_defs is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> return <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) </s>
