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()
(_etype26, _size23) = iprot.readSetBegin()
for _i27 in range(_size23):
_elem28 = iprot.readBinary()
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 range(_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 range(_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()