Declarative data flow library