Decentralized self-adaptation for elastic Data Stream Processing