Compose stream to process data. Support read/transform/write work-flows Include multiple read sources or multiple writes