in python/S3Sink/streaming-file-sink.py [0:0]
def property_map(props, property_group_id): for prop in props: if prop["PropertyGroupId"] == property_group_id: return prop["PropertyMap"]