A Framework for Data-Flow Distributed Processing