Client API for data flows.