A data engineer needs to perform real-time analytics on streaming data to detect fraudulent transactions as they occur. The analytics must allow for SQL-based queries to detect specific patterns or anomalies in the data stream. Which service should be used to achieve this?