in cassandra-thrift/v11/ttypes.py [0:0]
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('CfDef')
if self.keyspace is not None:
oprot.writeFieldBegin('keyspace', TType.STRING, 1)
oprot.writeString(self.keyspace)
oprot.writeFieldEnd()
if self.name is not None:
oprot.writeFieldBegin('name', TType.STRING, 2)
oprot.writeString(self.name)
oprot.writeFieldEnd()
if self.column_type is not None:
oprot.writeFieldBegin('column_type', TType.STRING, 3)
oprot.writeString(self.column_type)
oprot.writeFieldEnd()
if self.comparator_type is not None:
oprot.writeFieldBegin('comparator_type', TType.STRING, 5)
oprot.writeString(self.comparator_type)
oprot.writeFieldEnd()
if self.subcomparator_type is not None:
oprot.writeFieldBegin('subcomparator_type', TType.STRING, 6)
oprot.writeString(self.subcomparator_type)
oprot.writeFieldEnd()
if self.comment is not None:
oprot.writeFieldBegin('comment', TType.STRING, 8)
oprot.writeString(self.comment)
oprot.writeFieldEnd()
if self.row_cache_size is not None:
oprot.writeFieldBegin('row_cache_size', TType.DOUBLE, 9)
oprot.writeDouble(self.row_cache_size)
oprot.writeFieldEnd()
if self.key_cache_size is not None:
oprot.writeFieldBegin('key_cache_size', TType.DOUBLE, 11)
oprot.writeDouble(self.key_cache_size)
oprot.writeFieldEnd()
if self.read_repair_chance is not None:
oprot.writeFieldBegin('read_repair_chance', TType.DOUBLE, 12)
oprot.writeDouble(self.read_repair_chance)
oprot.writeFieldEnd()
if self.column_metadata is not None:
oprot.writeFieldBegin('column_metadata', TType.LIST, 13)
oprot.writeListBegin(TType.STRUCT, len(self.column_metadata))
for iter107 in self.column_metadata:
iter107.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.gc_grace_seconds is not None:
oprot.writeFieldBegin('gc_grace_seconds', TType.I32, 14)
oprot.writeI32(self.gc_grace_seconds)
oprot.writeFieldEnd()
if self.default_validation_class is not None:
oprot.writeFieldBegin('default_validation_class', TType.STRING, 15)
oprot.writeString(self.default_validation_class)
oprot.writeFieldEnd()
if self.id is not None:
oprot.writeFieldBegin('id', TType.I32, 16)
oprot.writeI32(self.id)
oprot.writeFieldEnd()
if self.min_compaction_threshold is not None:
oprot.writeFieldBegin('min_compaction_threshold', TType.I32, 17)
oprot.writeI32(self.min_compaction_threshold)
oprot.writeFieldEnd()
if self.max_compaction_threshold is not None:
oprot.writeFieldBegin('max_compaction_threshold', TType.I32, 18)
oprot.writeI32(self.max_compaction_threshold)
oprot.writeFieldEnd()
if self.row_cache_save_period_in_seconds is not None:
oprot.writeFieldBegin('row_cache_save_period_in_seconds', TType.I32, 19)
oprot.writeI32(self.row_cache_save_period_in_seconds)
oprot.writeFieldEnd()
if self.key_cache_save_period_in_seconds is not None:
oprot.writeFieldBegin('key_cache_save_period_in_seconds', TType.I32, 20)
oprot.writeI32(self.key_cache_save_period_in_seconds)
oprot.writeFieldEnd()
if self.memtable_flush_after_mins is not None:
oprot.writeFieldBegin('memtable_flush_after_mins', TType.I32, 21)
oprot.writeI32(self.memtable_flush_after_mins)
oprot.writeFieldEnd()
if self.memtable_throughput_in_mb is not None:
oprot.writeFieldBegin('memtable_throughput_in_mb', TType.I32, 22)
oprot.writeI32(self.memtable_throughput_in_mb)
oprot.writeFieldEnd()
if self.memtable_operations_in_millions is not None:
oprot.writeFieldBegin('memtable_operations_in_millions', TType.DOUBLE, 23)
oprot.writeDouble(self.memtable_operations_in_millions)
oprot.writeFieldEnd()
if self.replicate_on_write is not None:
oprot.writeFieldBegin('replicate_on_write', TType.BOOL, 24)
oprot.writeBool(self.replicate_on_write)
oprot.writeFieldEnd()
if self.merge_shards_chance is not None:
oprot.writeFieldBegin('merge_shards_chance', TType.DOUBLE, 25)
oprot.writeDouble(self.merge_shards_chance)
oprot.writeFieldEnd()
if self.key_validation_class is not None:
oprot.writeFieldBegin('key_validation_class', TType.STRING, 26)
oprot.writeString(self.key_validation_class)
oprot.writeFieldEnd()
if self.row_cache_provider is not None:
oprot.writeFieldBegin('row_cache_provider', TType.STRING, 27)
oprot.writeString(self.row_cache_provider)
oprot.writeFieldEnd()
if self.key_alias is not None:
oprot.writeFieldBegin('key_alias', TType.STRING, 28)
oprot.writeString(self.key_alias)
oprot.writeFieldEnd()
if self.compaction_strategy is not None:
oprot.writeFieldBegin('compaction_strategy', TType.STRING, 29)
oprot.writeString(self.compaction_strategy)
oprot.writeFieldEnd()
if self.compaction_strategy_options is not None:
oprot.writeFieldBegin('compaction_strategy_options', TType.MAP, 30)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.compaction_strategy_options))
for kiter108,viter109 in list(self.compaction_strategy_options.items()):
oprot.writeString(kiter108)
oprot.writeString(viter109)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.row_cache_keys_to_save is not None:
oprot.writeFieldBegin('row_cache_keys_to_save', TType.I32, 31)
oprot.writeI32(self.row_cache_keys_to_save)
oprot.writeFieldEnd()
if self.compression_options is not None:
oprot.writeFieldBegin('compression_options', TType.MAP, 32)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.compression_options))
for kiter110,viter111 in list(self.compression_options.items()):
oprot.writeString(kiter110)
oprot.writeString(viter111)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.bloom_filter_fp_chance is not None:
oprot.writeFieldBegin('bloom_filter_fp_chance', TType.DOUBLE, 33)
oprot.writeDouble(self.bloom_filter_fp_chance)
oprot.writeFieldEnd()
if self.caching is not None:
oprot.writeFieldBegin('caching', TType.STRING, 34)
oprot.writeString(self.caching)
oprot.writeFieldEnd()
if self.column_aliases is not None:
oprot.writeFieldBegin('column_aliases', TType.LIST, 35)
oprot.writeListBegin(TType.STRING, len(self.column_aliases))
for iter112 in self.column_aliases:
oprot.writeString(iter112)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.value_alias is not None:
oprot.writeFieldBegin('value_alias', TType.STRING, 36)
oprot.writeString(self.value_alias)
oprot.writeFieldEnd()
if self.dclocal_read_repair_chance is not None:
oprot.writeFieldBegin('dclocal_read_repair_chance', TType.DOUBLE, 37)
oprot.writeDouble(self.dclocal_read_repair_chance)
oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()