Drift interview question

Resolve a code function that need to split a data pipeline