頂級開源與商業(yè)流分析平臺:

?aming, Apache Samza, Apache Storm

Commercial: IBM, Software AG, Azure Stream Analytics, DataTorrent, StreamAnalytix, SQLstream Blaze, SAP Event Stream Processor, Oracle Stream Analytics, TIBCO’s Event Analytics, Striim, Informatica, WSO2 Complex Event Processor, SAS Event Stream Processing, Cisco Connected Streaming Analytics.

?開源流分析平臺：

Apache Flink，Spark Streaming，Apache Samza，Apache Storm

?商業(yè)流分析平臺：

IBM, Software AG, Azure Stream Analytics，DataTorrent，StreamAnalytix，SQLstream Blaze，SAP Event Stream Processor，Oracle Stream Analytics，TIBCO’s Event Analytics，Striim，Informatica，WSO2 Complex Event Processor，SAS Event Stream Processing，Cisco Connected Streaming Analytics

頂級開源分析平臺

?1、Apache Flink是一個分布式流和批量數(shù)據(jù)處理的開源平臺。Flink的核心是一個流動數(shù)據(jù)流引擎，提供數(shù)據(jù)分發(fā)、通信和容錯數(shù)據(jù)流上的分布式計算。Flink包含了幾個API，以供創(chuàng)建應(yīng)用程序來使用Flink引擎，其中有：用于嵌入在Java和Scala的無限流（undounded streams）的DataStream API，用于嵌入在Java、Scala和Python中靜態(tài)數(shù)據(jù)的DataStream API，還有嵌入在Java與Scala中類SQL表達(dá)語言的Table API。

?2、Spark Streaming可以輕松建立可擴展的容錯流應(yīng)用。Spark Streaming帶來Apache Spark的語言集成API用于流處理，使你可以像寫批處理任務(wù)一樣寫流任務(wù)。它支持Java，Scala和Python。

3、Apache Samza是個分布式流處理架構(gòu)。它使用Apache Kafka來傳遞消息，Apache Hadoop Yarn用于容錯、隔離處理器、安全保障和資源管理。

?4、Apache Storm是一個免費開源的分布式實時計算系統(tǒng)。Storm可以輕松并可靠地處理無限數(shù)據(jù)流，能夠?qū)崟r做到如同Hadoop為批量處理所做的事。

頂級流分析平臺供應(yīng)商

5、IBM Streams是先進(jìn)的分析平臺，它允許用戶開發(fā)的應(yīng)用程序快速攝取、分析和關(guān)聯(lián)來自數(shù)以千計的數(shù)據(jù)流來源中的信息。該解決方案可以處理非常高的數(shù)據(jù)吞吐率，最高每秒可處理數(shù)百萬的事件或消息。

6、Software AG的Apama Streaming Analytics是一個提供流分析和在快速移動的大數(shù)據(jù)上智能自動操作的平臺。結(jié)合了事件處理、信息傳遞、內(nèi)存數(shù)據(jù)管理和可視化，這個平臺是一個完整的解決方案，能將物聯(lián)網(wǎng)產(chǎn)生的持續(xù)不斷的數(shù)據(jù)流轉(zhuǎn)化為有意義的實時指標(biāo)。

?7、Azure Stream Analytics可以讓你快速地開發(fā)和部署低成本的解決方案，以獲取來自設(shè)備、傳感器、基礎(chǔ)設(shè)施和應(yīng)用程序的實時洞察力。物聯(lián)網(wǎng)場景下可以使用它，比如實時遠(yuǎn)程管理和監(jiān)控，或從像手機和連網(wǎng)的汽車這樣的設(shè)備中獲得洞察力。

?8、DataTorrent的平臺是一個強大的實時流分析解決方案，簡化了實時大數(shù)據(jù)應(yīng)用的開發(fā)和運行。DataTorrent的整套開源Hadoop和商用硬件用于大規(guī)模實時流處理。該平臺旨在分清應(yīng)用程序邏輯和運行時間操作之間的區(qū)別。這使開發(fā)人員能夠?qū)Ｗ⒂谒麄兊拇a，而不是在管理上。有了DataTorrent，應(yīng)用程序自動縮放和自我修復(fù)，不會有狀態(tài)丟失或信息丟失，也沒有人為干預(yù)或代碼更改。

?9、StreamAnalytix是一個多引擎、企業(yè)級、基于開源的平臺。支持Apache Storm和Spark Streaming，StreamAnalytix旨在為任意一個垂直行業(yè)、數(shù)據(jù)格式和使用案例快速構(gòu)建和部署流分析應(yīng)用。能夠在幾分鐘內(nèi)用強大的視覺編輯器、內(nèi)置和包括HDFS、Amazson S3、Kafka、Cassandra和Elasticsearch在內(nèi)的資源創(chuàng)建出實時流數(shù)據(jù)分析應(yīng)用， 輕松連接不同的管道與集成子系統(tǒng)，并通過可重復(fù)使用的自定義操作來擴展自帶的資源。

?10、SQLstream Blaze是一個實時操作智能流處理套件，適用于高容量、高速率的機器數(shù)據(jù)的集成、分析和可視化。SQLstream Blaze包括核心流處理器、S-服務(wù)器，有供開發(fā)人員和企業(yè)高權(quán)限用戶使用的實時可視化產(chǎn)品、網(wǎng)絡(luò)管理工具和一個為機器數(shù)據(jù)以及企業(yè)整合用的代理適配器綜合套件。

?11、SAP Event Stream Processor是一個捕捉、分析并在實時事件流上操作的事件處理平臺。它分析并在事件上操作，因為它們與SAP Event Stream Processor一同發(fā)生，并且提供實時流處理和分析，最大限度地提高響應(yīng)速度和敏捷性，充分利用物聯(lián)網(wǎng)，開發(fā)擁有嵌入式CEP功能的新應(yīng)用。

?12、Oracle Stream Analytics平臺提供了一個吸引人的組合：一個易于使用的視覺界面以供快速創(chuàng)建和動態(tài)改變實時流分析應(yīng)用，同時提供全方位的運行時間平臺來一起管理和執(zhí)行這些解決方案。

?13、TIBCO的事件驅(qū)動解決方案可以助你通過增加傳統(tǒng)數(shù)據(jù)的智能處理和挖掘可能改變公司的行動來發(fā)現(xiàn)洞察力。 TIBCO的Event Analytics解決方案使得與機器的交互、協(xié)作都更容易，也使動作速度比以往任何時候都快。TIBCO提供一個事件處理和流分析產(chǎn)品的套裝，讓你獲得實時的、可操作的運營智能，更迅速地做出更好的決策，與此同時，智能是相關(guān)的，可以采取措施提升運營成果。

?14、Striim結(jié)合了流數(shù)據(jù)集成和流運營智能于一個平臺。 Striim使我們能夠關(guān)聯(lián)多個數(shù)據(jù)流中的流信息和異常檢測，有能力在數(shù)據(jù)移動的時候識別感興趣的事件及其模式。

?15、Informatica的解決方案已進(jìn)行了優(yōu)化，以收集和流結(jié)構(gòu)化的、非結(jié)構(gòu)化的或機器數(shù)據(jù)直接進(jìn)入高性能數(shù)據(jù)倉庫應(yīng)用、Hadoop或任何分析平臺。它提供訪問并集成新的數(shù)據(jù)源，通過LAN或WAN采集流數(shù)據(jù)，在加載和重定向負(fù)載以優(yōu)化性能（如ELT mode）之前，對數(shù)據(jù)進(jìn)行修正、標(biāo)準(zhǔn)化和去重。

?16、WSO2 Complex Event Processor提供實時分析，以幫助識別多個數(shù)據(jù)源中最有意義的事件和模式，分析其影響，并實時采取行動。它將實時和批量分析數(shù)據(jù)整合到一個平臺，通過機器學(xué)習(xí)達(dá)成預(yù)測分析來支持物聯(lián)網(wǎng)解決方案，以及移動和網(wǎng)頁應(yīng)用的多重需求。

?17、SAS Event Stream Processing可以分析移動中的高速大數(shù)據(jù)，有助了解哪些需要采取行動，以及哪些可以忽略不計。事件流處理來自SAS的流數(shù)據(jù)質(zhì)量，為復(fù)雜模式匹配預(yù)置解析表達(dá)式和高級分析集成。

?18、Cisco Connected Streaming Analytics（CSA）平臺提供來自多個數(shù)據(jù)源的高速流實時數(shù)據(jù)的洞察力，因此，你可以立即采取行動。CSA適用于廣泛的工業(yè)和商業(yè)應(yīng)用情況。