in src/main/python/accumulo/ttypes.py [0:0]
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.SET:
self.authorizations = set()
(_etype47, _size44) = iprot.readSetBegin()
for _i48 in range(_size44):
_elem49 = iprot.readBinary()
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 range(_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 range(_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 range(_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()