Transwarp Stream real time stream processing endgine delivers great stream computing capability, supports complex application logic. Information from production systems enters computing clusters via real time message queues. Then it is processed via pipelines inside clusters to complete complex service computations including data conversion, characteristics extraction, strategy inspection and analysis warning. The results of such computations are eventually output to storage clusters such as Hyperbase to create real time warning and display pages. The system is highly scalable and highly fault-tolerant. It has large throughput and low latency. Transwarp Stream has been successfully applied to real-time warning, risk control, online statistics and mining based on real-time data (such as sensor data).