in datahub/models/params.py [0:0]
def content(self):
data = {
"ShardCount": self._shard_count,
"Lifecycle": self._life_cycle,
"RecordType": self._record_type.value,
"Comment": self._comment
}
if RecordType.TUPLE == self._record_type:
if isinstance(self._record_schema, RecordSchema):
data['RecordSchema'] = self._record_schema.to_json_string()
else:
data['RecordSchema'] = self._record_schema
if self._extend_mode is not None:
data['ExpandMode'] = 'extend' if self._extend_mode else 'split'
return json.dumps(data)