in cassandra-thrift/v11/ttypes.py [0:0]
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.keyspace = iprot.readString();
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.column_type = iprot.readString();
else:
iprot.skip(ftype)
elif fid == 5:
if ftype == TType.STRING:
self.comparator_type = iprot.readString();
else:
iprot.skip(ftype)
elif fid == 6:
if ftype == TType.STRING:
self.subcomparator_type = iprot.readString();
else:
iprot.skip(ftype)
elif fid == 8:
if ftype == TType.STRING:
self.comment = iprot.readString();
else:
iprot.skip(ftype)
elif fid == 12:
if ftype == TType.DOUBLE:
self.read_repair_chance = iprot.readDouble();
else:
iprot.skip(ftype)
elif fid == 13:
if ftype == TType.LIST:
self.column_metadata = []
(_etype84, _size81) = iprot.readListBegin()
for _i85 in range(_size81):
_elem86 = ColumnDef()
_elem86.read(iprot)
self.column_metadata.append(_elem86)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 14:
if ftype == TType.I32:
self.gc_grace_seconds = iprot.readI32();
else:
iprot.skip(ftype)
elif fid == 15:
if ftype == TType.STRING:
self.default_validation_class = iprot.readString();
else:
iprot.skip(ftype)
elif fid == 16:
if ftype == TType.I32:
self.id = iprot.readI32();
else:
iprot.skip(ftype)
elif fid == 17:
if ftype == TType.I32:
self.min_compaction_threshold = iprot.readI32();
else:
iprot.skip(ftype)
elif fid == 18:
if ftype == TType.I32:
self.max_compaction_threshold = iprot.readI32();
else:
iprot.skip(ftype)
elif fid == 24:
if ftype == TType.BOOL:
self.replicate_on_write = iprot.readBool();
else:
iprot.skip(ftype)
elif fid == 26:
if ftype == TType.STRING:
self.key_validation_class = iprot.readString();
else:
iprot.skip(ftype)
elif fid == 28:
if ftype == TType.STRING:
self.key_alias = iprot.readString();
else:
iprot.skip(ftype)
elif fid == 29:
if ftype == TType.STRING:
self.compaction_strategy = iprot.readString();
else:
iprot.skip(ftype)
elif fid == 30:
if ftype == TType.MAP:
self.compaction_strategy_options = {}
(_ktype88, _vtype89, _size87 ) = iprot.readMapBegin()
for _i91 in range(_size87):
_key92 = iprot.readString();
_val93 = iprot.readString();
self.compaction_strategy_options[_key92] = _val93
iprot.readMapEnd()
else:
iprot.skip(ftype)
elif fid == 32:
if ftype == TType.MAP:
self.compression_options = {}
(_ktype95, _vtype96, _size94 ) = iprot.readMapBegin()
for _i98 in range(_size94):
_key99 = iprot.readString();
_val100 = iprot.readString();
self.compression_options[_key99] = _val100
iprot.readMapEnd()
else:
iprot.skip(ftype)
elif fid == 33:
if ftype == TType.DOUBLE:
self.bloom_filter_fp_chance = iprot.readDouble();
else:
iprot.skip(ftype)
elif fid == 34:
if ftype == TType.STRING:
self.caching = iprot.readString();
else:
iprot.skip(ftype)
elif fid == 35:
if ftype == TType.LIST:
self.column_aliases = []
(_etype104, _size101) = iprot.readListBegin()
for _i105 in range(_size101):
_elem106 = iprot.readString();
self.column_aliases.append(_elem106)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 36:
if ftype == TType.STRING:
self.value_alias = iprot.readString();
else:
iprot.skip(ftype)
elif fid == 37:
if ftype == TType.DOUBLE:
self.dclocal_read_repair_chance = iprot.readDouble();
else:
iprot.skip(ftype)
elif fid == 9:
if ftype == TType.DOUBLE:
self.row_cache_size = iprot.readDouble();
else:
iprot.skip(ftype)
elif fid == 11:
if ftype == TType.DOUBLE:
self.key_cache_size = iprot.readDouble();
else:
iprot.skip(ftype)
elif fid == 19:
if ftype == TType.I32:
self.row_cache_save_period_in_seconds = iprot.readI32();
else:
iprot.skip(ftype)
elif fid == 20:
if ftype == TType.I32:
self.key_cache_save_period_in_seconds = iprot.readI32();
else:
iprot.skip(ftype)
elif fid == 21:
if ftype == TType.I32:
self.memtable_flush_after_mins = iprot.readI32();
else:
iprot.skip(ftype)
elif fid == 22:
if ftype == TType.I32:
self.memtable_throughput_in_mb = iprot.readI32();
else:
iprot.skip(ftype)
elif fid == 23:
if ftype == TType.DOUBLE:
self.memtable_operations_in_millions = iprot.readDouble();
else:
iprot.skip(ftype)
elif fid == 25:
if ftype == TType.DOUBLE:
self.merge_shards_chance = iprot.readDouble();
else:
iprot.skip(ftype)
elif fid == 27:
if ftype == TType.STRING:
self.row_cache_provider = iprot.readString();
else:
iprot.skip(ftype)
elif fid == 31:
if ftype == TType.I32:
self.row_cache_keys_to_save = iprot.readI32();
else:
iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
iprot.readStructEnd()