Updated schema for the new streaming process