A reactive flow-based platform and framework for real-time analytics and actions