Function pipeDataSource