随着流计算的不断发展，客户可以使用流计算引擎开发出越来越复杂的实时应用，总体上流处理应用可以分为两类：实时数据集成和实时数据分析。实时数据集成是现代数据架构的基本需求，也是现在企业想要充分发挥大数据、云计算等技术的重要一步。实时数据集成主要功能是进行实时ETL，对实时数据进行清洗、过滤、加工之后，存到目标数据存储，包括实时数据存储、大数据存储以及传统关系数据库等，并在此之上构建不同的应用。

实时数据分析则主要应用在复杂分析场景。通过对实时数据进行统计计算、和历史数据关联分析等复杂处理，生成高阶的汇总的信息，实时展示Dashboard，同时可以辅助领导层进行决策判断。另外通过复杂事件模式、规则等判断，分析出海量数据中存在的风险和机遇，以便及时作出响应。

Transwarp Slipstream 是星环科技自主研发的企业级、高性能实时流计算引擎，支撑百万级高吞吐、毫秒级低延时业务需求。Slipstream 支持事件驱动和微批处理两种模式，支持exactly-once语义、复杂事件处理(CEP)、规则引擎等功能，支持SQL编程与开发。Slipstream帮助用户快速开发实时数据仓库、实时报表分析、实时智能推荐、实时欺诈检测与风险控制等应用。 Transwarp Slipstream主要包括StreamSQL【流式SQL】、Streaming Procedural SQL【流式存储过程】、Streaming CEP【流式复杂事件处理】、Streaming Rule Engine【流式规则引擎】、Streaming Calculus【流式微积分】、Streaming Machine Learning【流式机器学习】和 Slipboard【流计算监控管理平台】。

适用场景

星环Slipstream引擎目前已经在多个行业数百个生产集群中部署适用，其适用的场景包括但不限于：

金融行业：消息总线、实时数仓、实时风控、实时推荐、智能投顾等

交通行业：智慧城市、节能减排、实时研判、实时违法预警等

能源行业：设备故障检测、预测性维护等

电信行业：垃圾短信检测、精准营销等电商行业：实时推荐、行为分析等

Transwarp Slipstream分布式实时流计算引擎白皮书

Transwarp Slipstream分布式实时流计算引擎白皮书

内容简介

内容简介