Domain-specific language for stream processing or data management in a relational database management system