A framework for data-flow distributed processing