Split ChangeStream into Raw/Processed Stream