You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by ct...@apache.org on 2017/02/09 19:29:31 UTC
[03/41] accumulo git commit: ACCUMULO-4551 Add thrift-gen changes
from 0.10.0
http://git-wip-us.apache.org/repos/asf/accumulo/blob/62bbce43/proxy/src/main/python/ttypes.py
----------------------------------------------------------------------
diff --git a/proxy/src/main/python/ttypes.py b/proxy/src/main/python/ttypes.py
index 87a977d..69269bc 100644
--- a/proxy/src/main/python/ttypes.py
+++ b/proxy/src/main/python/ttypes.py
@@ -13,3355 +13,3143 @@
# See the License for the specific language governing permissions and
# limitations under the License.
#
-# Autogenerated by Thrift Compiler (0.9.3)
+# Autogenerated by Thrift Compiler (0.10.0)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
# options string: py
#
-from thrift.Thrift import TType, TMessageType, TException, TApplicationException
+from thrift.Thrift import TType, TMessageType, TFrozenDict, TException, TApplicationException
+from thrift.protocol.TProtocol import TProtocolException
+import sys
from thrift.transport import TTransport
-from thrift.protocol import TBinaryProtocol, TProtocol
-try:
- from thrift.protocol import fastbinary
-except:
- fastbinary = None
-
-
-class PartialKey:
- ROW = 0
- ROW_COLFAM = 1
- ROW_COLFAM_COLQUAL = 2
- ROW_COLFAM_COLQUAL_COLVIS = 3
- ROW_COLFAM_COLQUAL_COLVIS_TIME = 4
- ROW_COLFAM_COLQUAL_COLVIS_TIME_DEL = 5
-
- _VALUES_TO_NAMES = {
- 0: "ROW",
- 1: "ROW_COLFAM",
- 2: "ROW_COLFAM_COLQUAL",
- 3: "ROW_COLFAM_COLQUAL_COLVIS",
- 4: "ROW_COLFAM_COLQUAL_COLVIS_TIME",
- 5: "ROW_COLFAM_COLQUAL_COLVIS_TIME_DEL",
- }
-
- _NAMES_TO_VALUES = {
- "ROW": 0,
- "ROW_COLFAM": 1,
- "ROW_COLFAM_COLQUAL": 2,
- "ROW_COLFAM_COLQUAL_COLVIS": 3,
- "ROW_COLFAM_COLQUAL_COLVIS_TIME": 4,
- "ROW_COLFAM_COLQUAL_COLVIS_TIME_DEL": 5,
- }
-
-class TablePermission:
- READ = 2
- WRITE = 3
- BULK_IMPORT = 4
- ALTER_TABLE = 5
- GRANT = 6
- DROP_TABLE = 7
-
- _VALUES_TO_NAMES = {
- 2: "READ",
- 3: "WRITE",
- 4: "BULK_IMPORT",
- 5: "ALTER_TABLE",
- 6: "GRANT",
- 7: "DROP_TABLE",
- }
-
- _NAMES_TO_VALUES = {
- "READ": 2,
- "WRITE": 3,
- "BULK_IMPORT": 4,
- "ALTER_TABLE": 5,
- "GRANT": 6,
- "DROP_TABLE": 7,
- }
-
-class SystemPermission:
- GRANT = 0
- CREATE_TABLE = 1
- DROP_TABLE = 2
- ALTER_TABLE = 3
- CREATE_USER = 4
- DROP_USER = 5
- ALTER_USER = 6
- SYSTEM = 7
-
- _VALUES_TO_NAMES = {
- 0: "GRANT",
- 1: "CREATE_TABLE",
- 2: "DROP_TABLE",
- 3: "ALTER_TABLE",
- 4: "CREATE_USER",
- 5: "DROP_USER",
- 6: "ALTER_USER",
- 7: "SYSTEM",
- }
-
- _NAMES_TO_VALUES = {
- "GRANT": 0,
- "CREATE_TABLE": 1,
- "DROP_TABLE": 2,
- "ALTER_TABLE": 3,
- "CREATE_USER": 4,
- "DROP_USER": 5,
- "ALTER_USER": 6,
- "SYSTEM": 7,
- }
-
-class NamespacePermission:
- READ = 0
- WRITE = 1
- ALTER_NAMESPACE = 2
- GRANT = 3
- ALTER_TABLE = 4
- CREATE_TABLE = 5
- DROP_TABLE = 6
- BULK_IMPORT = 7
- DROP_NAMESPACE = 8
-
- _VALUES_TO_NAMES = {
- 0: "READ",
- 1: "WRITE",
- 2: "ALTER_NAMESPACE",
- 3: "GRANT",
- 4: "ALTER_TABLE",
- 5: "CREATE_TABLE",
- 6: "DROP_TABLE",
- 7: "BULK_IMPORT",
- 8: "DROP_NAMESPACE",
- }
-
- _NAMES_TO_VALUES = {
- "READ": 0,
- "WRITE": 1,
- "ALTER_NAMESPACE": 2,
- "GRANT": 3,
- "ALTER_TABLE": 4,
- "CREATE_TABLE": 5,
- "DROP_TABLE": 6,
- "BULK_IMPORT": 7,
- "DROP_NAMESPACE": 8,
- }
-
-class ScanType:
- SINGLE = 0
- BATCH = 1
-
- _VALUES_TO_NAMES = {
- 0: "SINGLE",
- 1: "BATCH",
- }
-
- _NAMES_TO_VALUES = {
- "SINGLE": 0,
- "BATCH": 1,
- }
-
-class ScanState:
- IDLE = 0
- RUNNING = 1
- QUEUED = 2
-
- _VALUES_TO_NAMES = {
- 0: "IDLE",
- 1: "RUNNING",
- 2: "QUEUED",
- }
-
- _NAMES_TO_VALUES = {
- "IDLE": 0,
- "RUNNING": 1,
- "QUEUED": 2,
- }
-
-class ConditionalStatus:
- ACCEPTED = 0
- REJECTED = 1
- VIOLATED = 2
- UNKNOWN = 3
- INVISIBLE_VISIBILITY = 4
-
- _VALUES_TO_NAMES = {
- 0: "ACCEPTED",
- 1: "REJECTED",
- 2: "VIOLATED",
- 3: "UNKNOWN",
- 4: "INVISIBLE_VISIBILITY",
- }
-
- _NAMES_TO_VALUES = {
- "ACCEPTED": 0,
- "REJECTED": 1,
- "VIOLATED": 2,
- "UNKNOWN": 3,
- "INVISIBLE_VISIBILITY": 4,
- }
-
-class Durability:
- DEFAULT = 0
- NONE = 1
- LOG = 2
- FLUSH = 3
- SYNC = 4
-
- _VALUES_TO_NAMES = {
- 0: "DEFAULT",
- 1: "NONE",
- 2: "LOG",
- 3: "FLUSH",
- 4: "SYNC",
- }
-
- _NAMES_TO_VALUES = {
- "DEFAULT": 0,
- "NONE": 1,
- "LOG": 2,
- "FLUSH": 3,
- "SYNC": 4,
- }
-
-class CompactionType:
- MINOR = 0
- MERGE = 1
- MAJOR = 2
- FULL = 3
-
- _VALUES_TO_NAMES = {
- 0: "MINOR",
- 1: "MERGE",
- 2: "MAJOR",
- 3: "FULL",
- }
-
- _NAMES_TO_VALUES = {
- "MINOR": 0,
- "MERGE": 1,
- "MAJOR": 2,
- "FULL": 3,
- }
-
-class CompactionReason:
- USER = 0
- SYSTEM = 1
- CHOP = 2
- IDLE = 3
- CLOSE = 4
-
- _VALUES_TO_NAMES = {
- 0: "USER",
- 1: "SYSTEM",
- 2: "CHOP",
- 3: "IDLE",
- 4: "CLOSE",
- }
-
- _NAMES_TO_VALUES = {
- "USER": 0,
- "SYSTEM": 1,
- "CHOP": 2,
- "IDLE": 3,
- "CLOSE": 4,
- }
-
-class IteratorScope:
- MINC = 0
- MAJC = 1
- SCAN = 2
-
- _VALUES_TO_NAMES = {
- 0: "MINC",
- 1: "MAJC",
- 2: "SCAN",
- }
-
- _NAMES_TO_VALUES = {
- "MINC": 0,
- "MAJC": 1,
- "SCAN": 2,
- }
-
-class TimeType:
- LOGICAL = 0
- MILLIS = 1
-
- _VALUES_TO_NAMES = {
- 0: "LOGICAL",
- 1: "MILLIS",
- }
-
- _NAMES_TO_VALUES = {
- "LOGICAL": 0,
- "MILLIS": 1,
- }
-
-
-class Key:
- """
- Attributes:
- - row
- - colFamily
- - colQualifier
- - colVisibility
- - timestamp
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'row', None, None, ), # 1
- (2, TType.STRING, 'colFamily', None, None, ), # 2
- (3, TType.STRING, 'colQualifier', None, None, ), # 3
- (4, TType.STRING, 'colVisibility', None, None, ), # 4
- (5, TType.I64, 'timestamp', None, 9223372036854775807, ), # 5
- )
-
- def __init__(self, row=None, colFamily=None, colQualifier=None, colVisibility=None, timestamp=thrift_spec[5][4],):
- self.row = row
- self.colFamily = colFamily
- self.colQualifier = colQualifier
- self.colVisibility = colVisibility
- self.timestamp = timestamp
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.row = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRING:
- self.colFamily = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRING:
- self.colQualifier = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.STRING:
- self.colVisibility = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.I64:
- self.timestamp = iprot.readI64()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('Key')
- if self.row is not None:
- oprot.writeFieldBegin('row', TType.STRING, 1)
- oprot.writeString(self.row)
- oprot.writeFieldEnd()
- if self.colFamily is not None:
- oprot.writeFieldBegin('colFamily', TType.STRING, 2)
- oprot.writeString(self.colFamily)
- oprot.writeFieldEnd()
- if self.colQualifier is not None:
- oprot.writeFieldBegin('colQualifier', TType.STRING, 3)
- oprot.writeString(self.colQualifier)
- oprot.writeFieldEnd()
- if self.colVisibility is not None:
- oprot.writeFieldBegin('colVisibility', TType.STRING, 4)
- oprot.writeString(self.colVisibility)
- oprot.writeFieldEnd()
- if self.timestamp is not None:
- oprot.writeFieldBegin('timestamp', TType.I64, 5)
- oprot.writeI64(self.timestamp)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.row)
- value = (value * 31) ^ hash(self.colFamily)
- value = (value * 31) ^ hash(self.colQualifier)
- value = (value * 31) ^ hash(self.colVisibility)
- value = (value * 31) ^ hash(self.timestamp)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class ColumnUpdate:
- """
- Attributes:
- - colFamily
- - colQualifier
- - colVisibility
- - timestamp
- - value
- - deleteCell
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'colFamily', None, None, ), # 1
- (2, TType.STRING, 'colQualifier', None, None, ), # 2
- (3, TType.STRING, 'colVisibility', None, None, ), # 3
- (4, TType.I64, 'timestamp', None, None, ), # 4
- (5, TType.STRING, 'value', None, None, ), # 5
- (6, TType.BOOL, 'deleteCell', None, None, ), # 6
- )
-
- def __init__(self, colFamily=None, colQualifier=None, colVisibility=None, timestamp=None, value=None, deleteCell=None,):
- self.colFamily = colFamily
- self.colQualifier = colQualifier
- self.colVisibility = colVisibility
- self.timestamp = timestamp
- self.value = value
- self.deleteCell = deleteCell
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.colFamily = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRING:
- self.colQualifier = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRING:
- self.colVisibility = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.I64:
- self.timestamp = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.STRING:
- self.value = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 6:
- if ftype == TType.BOOL:
- self.deleteCell = iprot.readBool()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('ColumnUpdate')
- if self.colFamily is not None:
- oprot.writeFieldBegin('colFamily', TType.STRING, 1)
- oprot.writeString(self.colFamily)
- oprot.writeFieldEnd()
- if self.colQualifier is not None:
- oprot.writeFieldBegin('colQualifier', TType.STRING, 2)
- oprot.writeString(self.colQualifier)
- oprot.writeFieldEnd()
- if self.colVisibility is not None:
- oprot.writeFieldBegin('colVisibility', TType.STRING, 3)
- oprot.writeString(self.colVisibility)
- oprot.writeFieldEnd()
- if self.timestamp is not None:
- oprot.writeFieldBegin('timestamp', TType.I64, 4)
- oprot.writeI64(self.timestamp)
- oprot.writeFieldEnd()
- if self.value is not None:
- oprot.writeFieldBegin('value', TType.STRING, 5)
- oprot.writeString(self.value)
- oprot.writeFieldEnd()
- if self.deleteCell is not None:
- oprot.writeFieldBegin('deleteCell', TType.BOOL, 6)
- oprot.writeBool(self.deleteCell)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.colFamily)
- value = (value * 31) ^ hash(self.colQualifier)
- value = (value * 31) ^ hash(self.colVisibility)
- value = (value * 31) ^ hash(self.timestamp)
- value = (value * 31) ^ hash(self.value)
- value = (value * 31) ^ hash(self.deleteCell)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class DiskUsage:
- """
- Attributes:
- - tables
- - usage
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.LIST, 'tables', (TType.STRING,None), None, ), # 1
- (2, TType.I64, 'usage', None, None, ), # 2
- )
-
- def __init__(self, tables=None, usage=None,):
- self.tables = tables
- self.usage = usage
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.LIST:
- self.tables = []
- (_etype3, _size0) = iprot.readListBegin()
- for _i4 in xrange(_size0):
- _elem5 = iprot.readString()
- self.tables.append(_elem5)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.I64:
- self.usage = iprot.readI64()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('DiskUsage')
- if self.tables is not None:
- oprot.writeFieldBegin('tables', TType.LIST, 1)
- oprot.writeListBegin(TType.STRING, len(self.tables))
- for iter6 in self.tables:
- oprot.writeString(iter6)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- if self.usage is not None:
- oprot.writeFieldBegin('usage', TType.I64, 2)
- oprot.writeI64(self.usage)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.tables)
- value = (value * 31) ^ hash(self.usage)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class KeyValue:
- """
- Attributes:
- - key
- - value
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRUCT, 'key', (Key, Key.thrift_spec), None, ), # 1
- (2, TType.STRING, 'value', None, None, ), # 2
- )
-
- def __init__(self, key=None, value=None,):
- self.key = key
- self.value = value
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRUCT:
- self.key = Key()
- self.key.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRING:
- self.value = iprot.readString()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('KeyValue')
- if self.key is not None:
- oprot.writeFieldBegin('key', TType.STRUCT, 1)
- self.key.write(oprot)
- oprot.writeFieldEnd()
- if self.value is not None:
- oprot.writeFieldBegin('value', TType.STRING, 2)
- oprot.writeString(self.value)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.key)
- value = (value * 31) ^ hash(self.value)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class ScanResult:
- """
- Attributes:
- - results
- - more
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.LIST, 'results', (TType.STRUCT,(KeyValue, KeyValue.thrift_spec)), None, ), # 1
- (2, TType.BOOL, 'more', None, None, ), # 2
- )
-
- def __init__(self, results=None, more=None,):
- self.results = results
- self.more = more
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.LIST:
- self.results = []
- (_etype10, _size7) = iprot.readListBegin()
- for _i11 in xrange(_size7):
- _elem12 = KeyValue()
- _elem12.read(iprot)
- self.results.append(_elem12)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.BOOL:
- self.more = iprot.readBool()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('ScanResult')
- if self.results is not None:
- oprot.writeFieldBegin('results', TType.LIST, 1)
- oprot.writeListBegin(TType.STRUCT, len(self.results))
- for iter13 in self.results:
- iter13.write(oprot)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- if self.more is not None:
- oprot.writeFieldBegin('more', TType.BOOL, 2)
- oprot.writeBool(self.more)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.results)
- value = (value * 31) ^ hash(self.more)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class Range:
- """
- Attributes:
- - start
- - startInclusive
- - stop
- - stopInclusive
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRUCT, 'start', (Key, Key.thrift_spec), None, ), # 1
- (2, TType.BOOL, 'startInclusive', None, None, ), # 2
- (3, TType.STRUCT, 'stop', (Key, Key.thrift_spec), None, ), # 3
- (4, TType.BOOL, 'stopInclusive', None, None, ), # 4
- )
-
- def __init__(self, start=None, startInclusive=None, stop=None, stopInclusive=None,):
- self.start = start
- self.startInclusive = startInclusive
- self.stop = stop
- self.stopInclusive = stopInclusive
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRUCT:
- self.start = Key()
- self.start.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.BOOL:
- self.startInclusive = iprot.readBool()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRUCT:
- self.stop = Key()
- self.stop.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.BOOL:
- self.stopInclusive = iprot.readBool()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('Range')
- if self.start is not None:
- oprot.writeFieldBegin('start', TType.STRUCT, 1)
- self.start.write(oprot)
- oprot.writeFieldEnd()
- if self.startInclusive is not None:
- oprot.writeFieldBegin('startInclusive', TType.BOOL, 2)
- oprot.writeBool(self.startInclusive)
- oprot.writeFieldEnd()
- if self.stop is not None:
- oprot.writeFieldBegin('stop', TType.STRUCT, 3)
- self.stop.write(oprot)
- oprot.writeFieldEnd()
- if self.stopInclusive is not None:
- oprot.writeFieldBegin('stopInclusive', TType.BOOL, 4)
- oprot.writeBool(self.stopInclusive)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.start)
- value = (value * 31) ^ hash(self.startInclusive)
- value = (value * 31) ^ hash(self.stop)
- value = (value * 31) ^ hash(self.stopInclusive)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class ScanColumn:
- """
- Attributes:
- - colFamily
- - colQualifier
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'colFamily', None, None, ), # 1
- (2, TType.STRING, 'colQualifier', None, None, ), # 2
- )
-
- def __init__(self, colFamily=None, colQualifier=None,):
- self.colFamily = colFamily
- self.colQualifier = colQualifier
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.colFamily = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRING:
- self.colQualifier = iprot.readString()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('ScanColumn')
- if self.colFamily is not None:
- oprot.writeFieldBegin('colFamily', TType.STRING, 1)
- oprot.writeString(self.colFamily)
- oprot.writeFieldEnd()
- if self.colQualifier is not None:
- oprot.writeFieldBegin('colQualifier', TType.STRING, 2)
- oprot.writeString(self.colQualifier)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.colFamily)
- value = (value * 31) ^ hash(self.colQualifier)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class IteratorSetting:
- """
- Attributes:
- - priority
- - name
- - iteratorClass
- - properties
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.I32, 'priority', None, None, ), # 1
- (2, TType.STRING, 'name', None, None, ), # 2
- (3, TType.STRING, 'iteratorClass', None, None, ), # 3
- (4, TType.MAP, 'properties', (TType.STRING,None,TType.STRING,None), None, ), # 4
- )
-
- def __init__(self, priority=None, name=None, iteratorClass=None, properties=None,):
- self.priority = priority
- self.name = name
- self.iteratorClass = iteratorClass
- self.properties = properties
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.I32:
- self.priority = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRING:
- self.name = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRING:
- self.iteratorClass = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.MAP:
- self.properties = {}
- (_ktype15, _vtype16, _size14 ) = iprot.readMapBegin()
- for _i18 in xrange(_size14):
- _key19 = iprot.readString()
- _val20 = iprot.readString()
- self.properties[_key19] = _val20
- iprot.readMapEnd()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('IteratorSetting')
- if self.priority is not None:
- oprot.writeFieldBegin('priority', TType.I32, 1)
- oprot.writeI32(self.priority)
- oprot.writeFieldEnd()
- if self.name is not None:
- oprot.writeFieldBegin('name', TType.STRING, 2)
- oprot.writeString(self.name)
- oprot.writeFieldEnd()
- if self.iteratorClass is not None:
- oprot.writeFieldBegin('iteratorClass', TType.STRING, 3)
- oprot.writeString(self.iteratorClass)
- oprot.writeFieldEnd()
- if self.properties is not None:
- oprot.writeFieldBegin('properties', TType.MAP, 4)
- oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.properties))
- for kiter21,viter22 in self.properties.items():
- oprot.writeString(kiter21)
- oprot.writeString(viter22)
- oprot.writeMapEnd()
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.priority)
- value = (value * 31) ^ hash(self.name)
- value = (value * 31) ^ hash(self.iteratorClass)
- value = (value * 31) ^ hash(self.properties)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class ScanOptions:
- """
- Attributes:
- - authorizations
- - range
- - columns
- - iterators
- - bufferSize
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.SET, 'authorizations', (TType.STRING,None), None, ), # 1
- (2, TType.STRUCT, 'range', (Range, Range.thrift_spec), None, ), # 2
- (3, TType.LIST, 'columns', (TType.STRUCT,(ScanColumn, ScanColumn.thrift_spec)), None, ), # 3
- (4, TType.LIST, 'iterators', (TType.STRUCT,(IteratorSetting, IteratorSetting.thrift_spec)), None, ), # 4
- (5, TType.I32, 'bufferSize', None, None, ), # 5
- )
-
- def __init__(self, authorizations=None, range=None, columns=None, iterators=None, bufferSize=None,):
- self.authorizations = authorizations
- self.range = range
- self.columns = columns
- self.iterators = iterators
- self.bufferSize = bufferSize
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.SET:
- self.authorizations = set()
- (_etype26, _size23) = iprot.readSetBegin()
- for _i27 in xrange(_size23):
- _elem28 = iprot.readString()
- self.authorizations.add(_elem28)
- iprot.readSetEnd()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRUCT:
- self.range = Range()
- self.range.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.LIST:
- self.columns = []
- (_etype32, _size29) = iprot.readListBegin()
- for _i33 in xrange(_size29):
- _elem34 = ScanColumn()
- _elem34.read(iprot)
- self.columns.append(_elem34)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.LIST:
- self.iterators = []
- (_etype38, _size35) = iprot.readListBegin()
- for _i39 in xrange(_size35):
- _elem40 = IteratorSetting()
- _elem40.read(iprot)
- self.iterators.append(_elem40)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.I32:
- self.bufferSize = iprot.readI32()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('ScanOptions')
- if self.authorizations is not None:
- oprot.writeFieldBegin('authorizations', TType.SET, 1)
- oprot.writeSetBegin(TType.STRING, len(self.authorizations))
- for iter41 in self.authorizations:
- oprot.writeString(iter41)
- oprot.writeSetEnd()
- oprot.writeFieldEnd()
- if self.range is not None:
- oprot.writeFieldBegin('range', TType.STRUCT, 2)
- self.range.write(oprot)
- oprot.writeFieldEnd()
- if self.columns is not None:
- oprot.writeFieldBegin('columns', TType.LIST, 3)
- oprot.writeListBegin(TType.STRUCT, len(self.columns))
- for iter42 in self.columns:
- iter42.write(oprot)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- if self.iterators is not None:
- oprot.writeFieldBegin('iterators', TType.LIST, 4)
- oprot.writeListBegin(TType.STRUCT, len(self.iterators))
- for iter43 in self.iterators:
- iter43.write(oprot)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- if self.bufferSize is not None:
- oprot.writeFieldBegin('bufferSize', TType.I32, 5)
- oprot.writeI32(self.bufferSize)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.authorizations)
- value = (value * 31) ^ hash(self.range)
- value = (value * 31) ^ hash(self.columns)
- value = (value * 31) ^ hash(self.iterators)
- value = (value * 31) ^ hash(self.bufferSize)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class BatchScanOptions:
- """
- Attributes:
- - authorizations
- - ranges
- - columns
- - iterators
- - threads
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.SET, 'authorizations', (TType.STRING,None), None, ), # 1
- (2, TType.LIST, 'ranges', (TType.STRUCT,(Range, Range.thrift_spec)), None, ), # 2
- (3, TType.LIST, 'columns', (TType.STRUCT,(ScanColumn, ScanColumn.thrift_spec)), None, ), # 3
- (4, TType.LIST, 'iterators', (TType.STRUCT,(IteratorSetting, IteratorSetting.thrift_spec)), None, ), # 4
- (5, TType.I32, 'threads', None, None, ), # 5
- )
-
- def __init__(self, authorizations=None, ranges=None, columns=None, iterators=None, threads=None,):
- self.authorizations = authorizations
- self.ranges = ranges
- self.columns = columns
- self.iterators = iterators
- self.threads = threads
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.SET:
- self.authorizations = set()
- (_etype47, _size44) = iprot.readSetBegin()
- for _i48 in xrange(_size44):
- _elem49 = iprot.readString()
- self.authorizations.add(_elem49)
- iprot.readSetEnd()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.LIST:
- self.ranges = []
- (_etype53, _size50) = iprot.readListBegin()
- for _i54 in xrange(_size50):
- _elem55 = Range()
- _elem55.read(iprot)
- self.ranges.append(_elem55)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.LIST:
- self.columns = []
- (_etype59, _size56) = iprot.readListBegin()
- for _i60 in xrange(_size56):
- _elem61 = ScanColumn()
- _elem61.read(iprot)
- self.columns.append(_elem61)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.LIST:
- self.iterators = []
- (_etype65, _size62) = iprot.readListBegin()
- for _i66 in xrange(_size62):
- _elem67 = IteratorSetting()
- _elem67.read(iprot)
- self.iterators.append(_elem67)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.I32:
- self.threads = iprot.readI32()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('BatchScanOptions')
- if self.authorizations is not None:
- oprot.writeFieldBegin('authorizations', TType.SET, 1)
- oprot.writeSetBegin(TType.STRING, len(self.authorizations))
- for iter68 in self.authorizations:
- oprot.writeString(iter68)
- oprot.writeSetEnd()
- oprot.writeFieldEnd()
- if self.ranges is not None:
- oprot.writeFieldBegin('ranges', TType.LIST, 2)
- oprot.writeListBegin(TType.STRUCT, len(self.ranges))
- for iter69 in self.ranges:
- iter69.write(oprot)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- if self.columns is not None:
- oprot.writeFieldBegin('columns', TType.LIST, 3)
- oprot.writeListBegin(TType.STRUCT, len(self.columns))
- for iter70 in self.columns:
- iter70.write(oprot)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- if self.iterators is not None:
- oprot.writeFieldBegin('iterators', TType.LIST, 4)
- oprot.writeListBegin(TType.STRUCT, len(self.iterators))
- for iter71 in self.iterators:
- iter71.write(oprot)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- if self.threads is not None:
- oprot.writeFieldBegin('threads', TType.I32, 5)
- oprot.writeI32(self.threads)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.authorizations)
- value = (value * 31) ^ hash(self.ranges)
- value = (value * 31) ^ hash(self.columns)
- value = (value * 31) ^ hash(self.iterators)
- value = (value * 31) ^ hash(self.threads)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class KeyValueAndPeek:
- """
- Attributes:
- - keyValue
- - hasNext
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRUCT, 'keyValue', (KeyValue, KeyValue.thrift_spec), None, ), # 1
- (2, TType.BOOL, 'hasNext', None, None, ), # 2
- )
-
- def __init__(self, keyValue=None, hasNext=None,):
- self.keyValue = keyValue
- self.hasNext = hasNext
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRUCT:
- self.keyValue = KeyValue()
- self.keyValue.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.BOOL:
- self.hasNext = iprot.readBool()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('KeyValueAndPeek')
- if self.keyValue is not None:
- oprot.writeFieldBegin('keyValue', TType.STRUCT, 1)
- self.keyValue.write(oprot)
- oprot.writeFieldEnd()
- if self.hasNext is not None:
- oprot.writeFieldBegin('hasNext', TType.BOOL, 2)
- oprot.writeBool(self.hasNext)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.keyValue)
- value = (value * 31) ^ hash(self.hasNext)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class KeyExtent:
- """
- Attributes:
- - tableId
- - endRow
- - prevEndRow
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'tableId', None, None, ), # 1
- (2, TType.STRING, 'endRow', None, None, ), # 2
- (3, TType.STRING, 'prevEndRow', None, None, ), # 3
- )
-
- def __init__(self, tableId=None, endRow=None, prevEndRow=None,):
- self.tableId = tableId
- self.endRow = endRow
- self.prevEndRow = prevEndRow
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.tableId = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRING:
- self.endRow = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRING:
- self.prevEndRow = iprot.readString()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('KeyExtent')
- if self.tableId is not None:
- oprot.writeFieldBegin('tableId', TType.STRING, 1)
- oprot.writeString(self.tableId)
- oprot.writeFieldEnd()
- if self.endRow is not None:
- oprot.writeFieldBegin('endRow', TType.STRING, 2)
- oprot.writeString(self.endRow)
- oprot.writeFieldEnd()
- if self.prevEndRow is not None:
- oprot.writeFieldBegin('prevEndRow', TType.STRING, 3)
- oprot.writeString(self.prevEndRow)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.tableId)
- value = (value * 31) ^ hash(self.endRow)
- value = (value * 31) ^ hash(self.prevEndRow)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class Column:
- """
- Attributes:
- - colFamily
- - colQualifier
- - colVisibility
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'colFamily', None, None, ), # 1
- (2, TType.STRING, 'colQualifier', None, None, ), # 2
- (3, TType.STRING, 'colVisibility', None, None, ), # 3
- )
-
- def __init__(self, colFamily=None, colQualifier=None, colVisibility=None,):
- self.colFamily = colFamily
- self.colQualifier = colQualifier
- self.colVisibility = colVisibility
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.colFamily = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRING:
- self.colQualifier = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRING:
- self.colVisibility = iprot.readString()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('Column')
- if self.colFamily is not None:
- oprot.writeFieldBegin('colFamily', TType.STRING, 1)
- oprot.writeString(self.colFamily)
- oprot.writeFieldEnd()
- if self.colQualifier is not None:
- oprot.writeFieldBegin('colQualifier', TType.STRING, 2)
- oprot.writeString(self.colQualifier)
- oprot.writeFieldEnd()
- if self.colVisibility is not None:
- oprot.writeFieldBegin('colVisibility', TType.STRING, 3)
- oprot.writeString(self.colVisibility)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.colFamily)
- value = (value * 31) ^ hash(self.colQualifier)
- value = (value * 31) ^ hash(self.colVisibility)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class Condition:
- """
- Attributes:
- - column
- - timestamp
- - value
- - iterators
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRUCT, 'column', (Column, Column.thrift_spec), None, ), # 1
- (2, TType.I64, 'timestamp', None, None, ), # 2
- (3, TType.STRING, 'value', None, None, ), # 3
- (4, TType.LIST, 'iterators', (TType.STRUCT,(IteratorSetting, IteratorSetting.thrift_spec)), None, ), # 4
- )
-
- def __init__(self, column=None, timestamp=None, value=None, iterators=None,):
- self.column = column
- self.timestamp = timestamp
- self.value = value
- self.iterators = iterators
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRUCT:
- self.column = Column()
- self.column.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.I64:
- self.timestamp = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRING:
- self.value = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.LIST:
- self.iterators = []
- (_etype75, _size72) = iprot.readListBegin()
- for _i76 in xrange(_size72):
- _elem77 = IteratorSetting()
- _elem77.read(iprot)
- self.iterators.append(_elem77)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('Condition')
- if self.column is not None:
- oprot.writeFieldBegin('column', TType.STRUCT, 1)
- self.column.write(oprot)
- oprot.writeFieldEnd()
- if self.timestamp is not None:
- oprot.writeFieldBegin('timestamp', TType.I64, 2)
- oprot.writeI64(self.timestamp)
- oprot.writeFieldEnd()
- if self.value is not None:
- oprot.writeFieldBegin('value', TType.STRING, 3)
- oprot.writeString(self.value)
- oprot.writeFieldEnd()
- if self.iterators is not None:
- oprot.writeFieldBegin('iterators', TType.LIST, 4)
- oprot.writeListBegin(TType.STRUCT, len(self.iterators))
- for iter78 in self.iterators:
- iter78.write(oprot)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.column)
- value = (value * 31) ^ hash(self.timestamp)
- value = (value * 31) ^ hash(self.value)
- value = (value * 31) ^ hash(self.iterators)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class ConditionalUpdates:
- """
- Attributes:
- - conditions
- - updates
- """
-
- thrift_spec = (
- None, # 0
- None, # 1
- (2, TType.LIST, 'conditions', (TType.STRUCT,(Condition, Condition.thrift_spec)), None, ), # 2
- (3, TType.LIST, 'updates', (TType.STRUCT,(ColumnUpdate, ColumnUpdate.thrift_spec)), None, ), # 3
- )
-
- def __init__(self, conditions=None, updates=None,):
- self.conditions = conditions
- self.updates = updates
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 2:
- if ftype == TType.LIST:
- self.conditions = []
- (_etype82, _size79) = iprot.readListBegin()
- for _i83 in xrange(_size79):
- _elem84 = Condition()
- _elem84.read(iprot)
- self.conditions.append(_elem84)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.LIST:
- self.updates = []
- (_etype88, _size85) = iprot.readListBegin()
- for _i89 in xrange(_size85):
- _elem90 = ColumnUpdate()
- _elem90.read(iprot)
- self.updates.append(_elem90)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('ConditionalUpdates')
- if self.conditions is not None:
- oprot.writeFieldBegin('conditions', TType.LIST, 2)
- oprot.writeListBegin(TType.STRUCT, len(self.conditions))
- for iter91 in self.conditions:
- iter91.write(oprot)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- if self.updates is not None:
- oprot.writeFieldBegin('updates', TType.LIST, 3)
- oprot.writeListBegin(TType.STRUCT, len(self.updates))
- for iter92 in self.updates:
- iter92.write(oprot)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.conditions)
- value = (value * 31) ^ hash(self.updates)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class ConditionalWriterOptions:
- """
- Attributes:
- - maxMemory
- - timeoutMs
- - threads
- - authorizations
- - durability
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.I64, 'maxMemory', None, None, ), # 1
- (2, TType.I64, 'timeoutMs', None, None, ), # 2
- (3, TType.I32, 'threads', None, None, ), # 3
- (4, TType.SET, 'authorizations', (TType.STRING,None), None, ), # 4
- (5, TType.I32, 'durability', None, None, ), # 5
- )
-
- def __init__(self, maxMemory=None, timeoutMs=None, threads=None, authorizations=None, durability=None,):
- self.maxMemory = maxMemory
- self.timeoutMs = timeoutMs
- self.threads = threads
- self.authorizations = authorizations
- self.durability = durability
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.I64:
- self.maxMemory = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.I64:
- self.timeoutMs = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.I32:
- self.threads = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.SET:
- self.authorizations = set()
- (_etype96, _size93) = iprot.readSetBegin()
- for _i97 in xrange(_size93):
- _elem98 = iprot.readString()
- self.authorizations.add(_elem98)
- iprot.readSetEnd()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.I32:
- self.durability = iprot.readI32()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('ConditionalWriterOptions')
- if self.maxMemory is not None:
- oprot.writeFieldBegin('maxMemory', TType.I64, 1)
- oprot.writeI64(self.maxMemory)
- oprot.writeFieldEnd()
- if self.timeoutMs is not None:
- oprot.writeFieldBegin('timeoutMs', TType.I64, 2)
- oprot.writeI64(self.timeoutMs)
- oprot.writeFieldEnd()
- if self.threads is not None:
- oprot.writeFieldBegin('threads', TType.I32, 3)
- oprot.writeI32(self.threads)
- oprot.writeFieldEnd()
- if self.authorizations is not None:
- oprot.writeFieldBegin('authorizations', TType.SET, 4)
- oprot.writeSetBegin(TType.STRING, len(self.authorizations))
- for iter99 in self.authorizations:
- oprot.writeString(iter99)
- oprot.writeSetEnd()
- oprot.writeFieldEnd()
- if self.durability is not None:
- oprot.writeFieldBegin('durability', TType.I32, 5)
- oprot.writeI32(self.durability)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.maxMemory)
- value = (value * 31) ^ hash(self.timeoutMs)
- value = (value * 31) ^ hash(self.threads)
- value = (value * 31) ^ hash(self.authorizations)
- value = (value * 31) ^ hash(self.durability)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class ActiveScan:
- """
- Attributes:
- - client
- - user
- - table
- - age
- - idleTime
- - type
- - state
- - extent
- - columns
- - iterators
- - authorizations
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'client', None, None, ), # 1
- (2, TType.STRING, 'user', None, None, ), # 2
- (3, TType.STRING, 'table', None, None, ), # 3
- (4, TType.I64, 'age', None, None, ), # 4
- (5, TType.I64, 'idleTime', None, None, ), # 5
- (6, TType.I32, 'type', None, None, ), # 6
- (7, TType.I32, 'state', None, None, ), # 7
- (8, TType.STRUCT, 'extent', (KeyExtent, KeyExtent.thrift_spec), None, ), # 8
- (9, TType.LIST, 'columns', (TType.STRUCT,(Column, Column.thrift_spec)), None, ), # 9
- (10, TType.LIST, 'iterators', (TType.STRUCT,(IteratorSetting, IteratorSetting.thrift_spec)), None, ), # 10
- (11, TType.LIST, 'authorizations', (TType.STRING,None), None, ), # 11
- )
-
- def __init__(self, client=None, user=None, table=None, age=None, idleTime=None, type=None, state=None, extent=None, columns=None, iterators=None, authorizations=None,):
- self.client = client
- self.user = user
- self.table = table
- self.age = age
- self.idleTime = idleTime
- self.type = type
- self.state = state
- self.extent = extent
- self.columns = columns
- self.iterators = iterators
- self.authorizations = authorizations
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.client = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRING:
- self.user = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRING:
- self.table = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.I64:
- self.age = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.I64:
- self.idleTime = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 6:
- if ftype == TType.I32:
- self.type = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 7:
- if ftype == TType.I32:
- self.state = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 8:
- if ftype == TType.STRUCT:
- self.extent = KeyExtent()
- self.extent.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 9:
- if ftype == TType.LIST:
- self.columns = []
- (_etype103, _size100) = iprot.readListBegin()
- for _i104 in xrange(_size100):
- _elem105 = Column()
- _elem105.read(iprot)
- self.columns.append(_elem105)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 10:
- if ftype == TType.LIST:
- self.iterators = []
- (_etype109, _size106) = iprot.readListBegin()
- for _i110 in xrange(_size106):
- _elem111 = IteratorSetting()
- _elem111.read(iprot)
- self.iterators.append(_elem111)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 11:
- if ftype == TType.LIST:
- self.authorizations = []
- (_etype115, _size112) = iprot.readListBegin()
- for _i116 in xrange(_size112):
- _elem117 = iprot.readString()
- self.authorizations.append(_elem117)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('ActiveScan')
- if self.client is not None:
- oprot.writeFieldBegin('client', TType.STRING, 1)
- oprot.writeString(self.client)
- oprot.writeFieldEnd()
- if self.user is not None:
- oprot.writeFieldBegin('user', TType.STRING, 2)
- oprot.writeString(self.user)
- oprot.writeFieldEnd()
- if self.table is not None:
- oprot.writeFieldBegin('table', TType.STRING, 3)
- oprot.writeString(self.table)
- oprot.writeFieldEnd()
- if self.age is not None:
- oprot.writeFieldBegin('age', TType.I64, 4)
- oprot.writeI64(self.age)
- oprot.writeFieldEnd()
- if self.idleTime is not None:
- oprot.writeFieldBegin('idleTime', TType.I64, 5)
- oprot.writeI64(self.idleTime)
- oprot.writeFieldEnd()
- if self.type is not None:
- oprot.writeFieldBegin('type', TType.I32, 6)
- oprot.writeI32(self.type)
- oprot.writeFieldEnd()
- if self.state is not None:
- oprot.writeFieldBegin('state', TType.I32, 7)
- oprot.writeI32(self.state)
- oprot.writeFieldEnd()
- if self.extent is not None:
- oprot.writeFieldBegin('extent', TType.STRUCT, 8)
- self.extent.write(oprot)
- oprot.writeFieldEnd()
- if self.columns is not None:
- oprot.writeFieldBegin('columns', TType.LIST, 9)
- oprot.writeListBegin(TType.STRUCT, len(self.columns))
- for iter118 in self.columns:
- iter118.write(oprot)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- if self.iterators is not None:
- oprot.writeFieldBegin('iterators', TType.LIST, 10)
- oprot.writeListBegin(TType.STRUCT, len(self.iterators))
- for iter119 in self.iterators:
- iter119.write(oprot)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- if self.authorizations is not None:
- oprot.writeFieldBegin('authorizations', TType.LIST, 11)
- oprot.writeListBegin(TType.STRING, len(self.authorizations))
- for iter120 in self.authorizations:
- oprot.writeString(iter120)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.client)
- value = (value * 31) ^ hash(self.user)
- value = (value * 31) ^ hash(self.table)
- value = (value * 31) ^ hash(self.age)
- value = (value * 31) ^ hash(self.idleTime)
- value = (value * 31) ^ hash(self.type)
- value = (value * 31) ^ hash(self.state)
- value = (value * 31) ^ hash(self.extent)
- value = (value * 31) ^ hash(self.columns)
- value = (value * 31) ^ hash(self.iterators)
- value = (value * 31) ^ hash(self.authorizations)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class ActiveCompaction:
- """
- Attributes:
- - extent
- - age
- - inputFiles
- - outputFile
- - type
- - reason
- - localityGroup
- - entriesRead
- - entriesWritten
- - iterators
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRUCT, 'extent', (KeyExtent, KeyExtent.thrift_spec), None, ), # 1
- (2, TType.I64, 'age', None, None, ), # 2
- (3, TType.LIST, 'inputFiles', (TType.STRING,None), None, ), # 3
- (4, TType.STRING, 'outputFile', None, None, ), # 4
- (5, TType.I32, 'type', None, None, ), # 5
- (6, TType.I32, 'reason', None, None, ), # 6
- (7, TType.STRING, 'localityGroup', None, None, ), # 7
- (8, TType.I64, 'entriesRead', None, None, ), # 8
- (9, TType.I64, 'entriesWritten', None, None, ), # 9
- (10, TType.LIST, 'iterators', (TType.STRUCT,(IteratorSetting, IteratorSetting.thrift_spec)), None, ), # 10
- )
-
- def __init__(self, extent=None, age=None, inputFiles=None, outputFile=None, type=None, reason=None, localityGroup=None, entriesRead=None, entriesWritten=None, iterators=None,):
- self.extent = extent
- self.age = age
- self.inputFiles = inputFiles
- self.outputFile = outputFile
- self.type = type
- self.reason = reason
- self.localityGroup = localityGroup
- self.entriesRead = entriesRead
- self.entriesWritten = entriesWritten
- self.iterators = iterators
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRUCT:
- self.extent = KeyExtent()
- self.extent.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.I64:
- self.age = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.LIST:
- self.inputFiles = []
- (_etype124, _size121) = iprot.readListBegin()
- for _i125 in xrange(_size121):
- _elem126 = iprot.readString()
- self.inputFiles.append(_elem126)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.STRING:
- self.outputFile = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.I32:
- self.type = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 6:
- if ftype == TType.I32:
- self.reason = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 7:
- if ftype == TType.STRING:
- self.localityGroup = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 8:
- if ftype == TType.I64:
- self.entriesRead = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 9:
- if ftype == TType.I64:
- self.entriesWritten = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 10:
- if ftype == TType.LIST:
- self.iterators = []
- (_etype130, _size127) = iprot.readListBegin()
- for _i131 in xrange(_size127):
- _elem132 = IteratorSetting()
- _elem132.read(iprot)
- self.iterators.append(_elem132)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('ActiveCompaction')
- if self.extent is not None:
- oprot.writeFieldBegin('extent', TType.STRUCT, 1)
- self.extent.write(oprot)
- oprot.writeFieldEnd()
- if self.age is not None:
- oprot.writeFieldBegin('age', TType.I64, 2)
- oprot.writeI64(self.age)
- oprot.writeFieldEnd()
- if self.inputFiles is not None:
- oprot.writeFieldBegin('inputFiles', TType.LIST, 3)
- oprot.writeListBegin(TType.STRING, len(self.inputFiles))
- for iter133 in self.inputFiles:
- oprot.writeString(iter133)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- if self.outputFile is not None:
- oprot.writeFieldBegin('outputFile', TType.STRING, 4)
- oprot.writeString(self.outputFile)
- oprot.writeFieldEnd()
- if self.type is not None:
- oprot.writeFieldBegin('type', TType.I32, 5)
- oprot.writeI32(self.type)
- oprot.writeFieldEnd()
- if self.reason is not None:
- oprot.writeFieldBegin('reason', TType.I32, 6)
- oprot.writeI32(self.reason)
- oprot.writeFieldEnd()
- if self.localityGroup is not None:
- oprot.writeFieldBegin('localityGroup', TType.STRING, 7)
- oprot.writeString(self.localityGroup)
- oprot.writeFieldEnd()
- if self.entriesRead is not None:
- oprot.writeFieldBegin('entriesRead', TType.I64, 8)
- oprot.writeI64(self.entriesRead)
- oprot.writeFieldEnd()
- if self.entriesWritten is not None:
- oprot.writeFieldBegin('entriesWritten', TType.I64, 9)
- oprot.writeI64(self.entriesWritten)
- oprot.writeFieldEnd()
- if self.iterators is not None:
- oprot.writeFieldBegin('iterators', TType.LIST, 10)
- oprot.writeListBegin(TType.STRUCT, len(self.iterators))
- for iter134 in self.iterators:
- iter134.write(oprot)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.extent)
- value = (value * 31) ^ hash(self.age)
- value = (value * 31) ^ hash(self.inputFiles)
- value = (value * 31) ^ hash(self.outputFile)
- value = (value * 31) ^ hash(self.type)
- value = (value * 31) ^ hash(self.reason)
- value = (value * 31) ^ hash(self.localityGroup)
- value = (value * 31) ^ hash(self.entriesRead)
- value = (value * 31) ^ hash(self.entriesWritten)
- value = (value * 31) ^ hash(self.iterators)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class WriterOptions:
- """
- Attributes:
- - maxMemory
- - latencyMs
- - timeoutMs
- - threads
- - durability
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.I64, 'maxMemory', None, None, ), # 1
- (2, TType.I64, 'latencyMs', None, None, ), # 2
- (3, TType.I64, 'timeoutMs', None, None, ), # 3
- (4, TType.I32, 'threads', None, None, ), # 4
- (5, TType.I32, 'durability', None, None, ), # 5
- )
-
- def __init__(self, maxMemory=None, latencyMs=None, timeoutMs=None, threads=None, durability=None,):
- self.maxMemory = maxMemory
- self.latencyMs = latencyMs
- self.timeoutMs = timeoutMs
- self.threads = threads
- self.durability = durability
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.I64:
- self.maxMemory = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.I64:
- self.latencyMs = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.I64:
- self.timeoutMs = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.I32:
- self.threads = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.I32:
- self.durability = iprot.readI32()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('WriterOptions')
- if self.maxMemory is not None:
- oprot.writeFieldBegin('maxMemory', TType.I64, 1)
- oprot.writeI64(self.maxMemory)
- oprot.writeFieldEnd()
- if self.latencyMs is not None:
- oprot.writeFieldBegin('latencyMs', TType.I64, 2)
- oprot.writeI64(self.latencyMs)
- oprot.writeFieldEnd()
- if self.timeoutMs is not None:
- oprot.writeFieldBegin('timeoutMs', TType.I64, 3)
- oprot.writeI64(self.timeoutMs)
- oprot.writeFieldEnd()
- if self.threads is not None:
- oprot.writeFieldBegin('threads', TType.I32, 4)
- oprot.writeI32(self.threads)
- oprot.writeFieldEnd()
- if self.durability is not None:
- oprot.writeFieldBegin('durability', TType.I32, 5)
- oprot.writeI32(self.durability)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.maxMemory)
- value = (value * 31) ^ hash(self.latencyMs)
- value = (value * 31) ^ hash(self.timeoutMs)
- value = (value * 31) ^ hash(self.threads)
- value = (value * 31) ^ hash(self.durability)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class CompactionStrategyConfig:
- """
- Attributes:
- - className
- - options
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'className', None, None, ), # 1
- (2, TType.MAP, 'options', (TType.STRING,None,TType.STRING,None), None, ), # 2
- )
-
- def __init__(self, className=None, options=None,):
- self.className = className
- self.options = options
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.className = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.MAP:
- self.options = {}
- (_ktype136, _vtype137, _size135 ) = iprot.readMapBegin()
- for _i139 in xrange(_size135):
- _key140 = iprot.readString()
- _val141 = iprot.readString()
- self.options[_key140] = _val141
- iprot.readMapEnd()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('CompactionStrategyConfig')
- if self.className is not None:
- oprot.writeFieldBegin('className', TType.STRING, 1)
- oprot.writeString(self.className)
- oprot.writeFieldEnd()
- if self.options is not None:
- oprot.writeFieldBegin('options', TType.MAP, 2)
- oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.options))
- for kiter142,viter143 in self.options.items():
- oprot.writeString(kiter142)
- oprot.writeString(viter143)
- oprot.writeMapEnd()
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.className)
- value = (value * 31) ^ hash(self.options)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
+
+
+class PartialKey(object):
+ ROW = 0
+ ROW_COLFAM = 1
+ ROW_COLFAM_COLQUAL = 2
+ ROW_COLFAM_COLQUAL_COLVIS = 3
+ ROW_COLFAM_COLQUAL_COLVIS_TIME = 4
+ ROW_COLFAM_COLQUAL_COLVIS_TIME_DEL = 5
+
+ _VALUES_TO_NAMES = {
+ 0: "ROW",
+ 1: "ROW_COLFAM",
+ 2: "ROW_COLFAM_COLQUAL",
+ 3: "ROW_COLFAM_COLQUAL_COLVIS",
+ 4: "ROW_COLFAM_COLQUAL_COLVIS_TIME",
+ 5: "ROW_COLFAM_COLQUAL_COLVIS_TIME_DEL",
+ }
+
+ _NAMES_TO_VALUES = {
+ "ROW": 0,
+ "ROW_COLFAM": 1,
+ "ROW_COLFAM_COLQUAL": 2,
+ "ROW_COLFAM_COLQUAL_COLVIS": 3,
+ "ROW_COLFAM_COLQUAL_COLVIS_TIME": 4,
+ "ROW_COLFAM_COLQUAL_COLVIS_TIME_DEL": 5,
+ }
+
+
+class TablePermission(object):
+ READ = 2
+ WRITE = 3
+ BULK_IMPORT = 4
+ ALTER_TABLE = 5
+ GRANT = 6
+ DROP_TABLE = 7
+
+ _VALUES_TO_NAMES = {
+ 2: "READ",
+ 3: "WRITE",
+ 4: "BULK_IMPORT",
+ 5: "ALTER_TABLE",
+ 6: "GRANT",
+ 7: "DROP_TABLE",
+ }
+
+ _NAMES_TO_VALUES = {
+ "READ": 2,
+ "WRITE": 3,
+ "BULK_IMPORT": 4,
+ "ALTER_TABLE": 5,
+ "GRANT": 6,
+ "DROP_TABLE": 7,
+ }
+
+
+class SystemPermission(object):
+ GRANT = 0
+ CREATE_TABLE = 1
+ DROP_TABLE = 2
+ ALTER_TABLE = 3
+ CREATE_USER = 4
+ DROP_USER = 5
+ ALTER_USER = 6
+ SYSTEM = 7
+
+ _VALUES_TO_NAMES = {
+ 0: "GRANT",
+ 1: "CREATE_TABLE",
+ 2: "DROP_TABLE",
+ 3: "ALTER_TABLE",
+ 4: "CREATE_USER",
+ 5: "DROP_USER",
+ 6: "ALTER_USER",
+ 7: "SYSTEM",
+ }
+
+ _NAMES_TO_VALUES = {
+ "GRANT": 0,
+ "CREATE_TABLE": 1,
+ "DROP_TABLE": 2,
+ "ALTER_TABLE": 3,
+ "CREATE_USER": 4,
+ "DROP_USER": 5,
+ "ALTER_USER": 6,
+ "SYSTEM": 7,
+ }
+
+
+class NamespacePermission(object):
+ READ = 0
+ WRITE = 1
+ ALTER_NAMESPACE = 2
+ GRANT = 3
+ ALTER_TABLE = 4
+ CREATE_TABLE = 5
+ DROP_TABLE = 6
+ BULK_IMPORT = 7
+ DROP_NAMESPACE = 8
+
+ _VALUES_TO_NAMES = {
+ 0: "READ",
+ 1: "WRITE",
+ 2: "ALTER_NAMESPACE",
+ 3: "GRANT",
+ 4: "ALTER_TABLE",
+ 5: "CREATE_TABLE",
+ 6: "DROP_TABLE",
+ 7: "BULK_IMPORT",
+ 8: "DROP_NAMESPACE",
+ }
+
+ _NAMES_TO_VALUES = {
+ "READ": 0,
+ "WRITE": 1,
+ "ALTER_NAMESPACE": 2,
+ "GRANT": 3,
+ "ALTER_TABLE": 4,
+ "CREATE_TABLE": 5,
+ "DROP_TABLE": 6,
+ "BULK_IMPORT": 7,
+ "DROP_NAMESPACE": 8,
+ }
+
+
+class ScanType(object):
+ SINGLE = 0
+ BATCH = 1
+
+ _VALUES_TO_NAMES = {
+ 0: "SINGLE",
+ 1: "BATCH",
+ }
+
+ _NAMES_TO_VALUES = {
+ "SINGLE": 0,
+ "BATCH": 1,
+ }
+
+
+class ScanState(object):
+ IDLE = 0
+ RUNNING = 1
+ QUEUED = 2
+
+ _VALUES_TO_NAMES = {
+ 0: "IDLE",
+ 1: "RUNNING",
+ 2: "QUEUED",
+ }
+
+ _NAMES_TO_VALUES = {
+ "IDLE": 0,
+ "RUNNING": 1,
+ "QUEUED": 2,
+ }
+
+
+class ConditionalStatus(object):
+ ACCEPTED = 0
+ REJECTED = 1
+ VIOLATED = 2
+ UNKNOWN = 3
+ INVISIBLE_VISIBILITY = 4
+
+ _VALUES_TO_NAMES = {
+ 0: "ACCEPTED",
+ 1: "REJECTED",
+ 2: "VIOLATED",
+ 3: "UNKNOWN",
+ 4: "INVISIBLE_VISIBILITY",
+ }
+
+ _NAMES_TO_VALUES = {
+ "ACCEPTED": 0,
+ "REJECTED": 1,
+ "VIOLATED": 2,
+ "UNKNOWN": 3,
+ "INVISIBLE_VISIBILITY": 4,
+ }
+
+
+class Durability(object):
+ DEFAULT = 0
+ NONE = 1
+ LOG = 2
+ FLUSH = 3
+ SYNC = 4
+
+ _VALUES_TO_NAMES = {
+ 0: "DEFAULT",
+ 1: "NONE",
+ 2: "LOG",
+ 3: "FLUSH",
+ 4: "SYNC",
+ }
+
+ _NAMES_TO_VALUES = {
+ "DEFAULT": 0,
+ "NONE": 1,
+ "LOG": 2,
+ "FLUSH": 3,
+ "SYNC": 4,
+ }
+
+
+class CompactionType(object):
+ MINOR = 0
+ MERGE = 1
+ MAJOR = 2
+ FULL = 3
+
+ _VALUES_TO_NAMES = {
+ 0: "MINOR",
+ 1: "MERGE",
+ 2: "MAJOR",
+ 3: "FULL",
+ }
+
+ _NAMES_TO_VALUES = {
+ "MINOR": 0,
+ "MERGE": 1,
+ "MAJOR": 2,
+ "FULL": 3,
+ }
+
+
+class CompactionReason(object):
+ USER = 0
+ SYSTEM = 1
+ CHOP = 2
+ IDLE = 3
+ CLOSE = 4
+
+ _VALUES_TO_NAMES = {
+ 0: "USER",
+ 1: "SYSTEM",
+ 2: "CHOP",
+ 3: "IDLE",
+ 4: "CLOSE",
+ }
+
+ _NAMES_TO_VALUES = {
+ "USER": 0,
+ "SYSTEM": 1,
+ "CHOP": 2,
+ "IDLE": 3,
+ "CLOSE": 4,
+ }
+
+
+class IteratorScope(object):
+ MINC = 0
+ MAJC = 1
+ SCAN = 2
+
+ _VALUES_TO_NAMES = {
+ 0: "MINC",
+ 1: "MAJC",
+ 2: "SCAN",
+ }
+
+ _NAMES_TO_VALUES = {
+ "MINC": 0,
+ "MAJC": 1,
+ "SCAN": 2,
+ }
+
+
+class TimeType(object):
+ LOGICAL = 0
+ MILLIS = 1
+
+ _VALUES_TO_NAMES = {
+ 0: "LOGICAL",
+ 1: "MILLIS",
+ }
+
+ _NAMES_TO_VALUES = {
+ "LOGICAL": 0,
+ "MILLIS": 1,
+ }
+
+
+class Key(object):
+ """
+ Attributes:
+ - row
+ - colFamily
+ - colQualifier
+ - colVisibility
+ - timestamp
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'row', 'BINARY', None, ), # 1
+ (2, TType.STRING, 'colFamily', 'BINARY', None, ), # 2
+ (3, TType.STRING, 'colQualifier', 'BINARY', None, ), # 3
+ (4, TType.STRING, 'colVisibility', 'BINARY', None, ), # 4
+ (5, TType.I64, 'timestamp', None, 9223372036854775807, ), # 5
+ )
+
+ def __init__(self, row=None, colFamily=None, colQualifier=None, colVisibility=None, timestamp=thrift_spec[5][4],):
+ self.row = row
+ self.colFamily = colFamily
+ self.colQualifier = colQualifier
+ self.colVisibility = colVisibility
+ self.timestamp = timestamp
+
+ def read(self, iprot):
+ if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
+ iprot._fast_decode(self, iprot, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.STRING:
+ self.row = iprot.readBinary()
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.colFamily = iprot.readBinary()
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRING:
+ self.colQualifier = iprot.readBinary()
+
<TRUNCATED>