核心優(yōu)勢
高吞吐和低延遲
支持Spark Streaming、Flink等流計(jì)算引擎，并且統(tǒng)一一套編程模型。借助多計(jì)算引擎支持，流計(jì)算服務(wù)可以根據(jù)需求選擇不同的計(jì)算引擎以適配高吞吐和低延遲場景需求。
可視化流程編排
支持在Web界面上以可視化方式進(jìn)行流計(jì)算流程編排，創(chuàng)建、修改大數(shù)據(jù)處理流程。
技術(shù)領(lǐng)先
支持維表解決方案、On Docker等；支持用戶自定義插件開發(fā)，并在算子、UDF等多層面支持客戶進(jìn)行擴(kuò)展,支持JDBC、Hive、Redis、Hbase、ES、Kafka等Sink。
數(shù)據(jù)共享
支持用戶以寫臨時表的方式將流計(jì)算中間結(jié)果進(jìn)行緩存，供其他流計(jì)算流程做為數(shù)據(jù)源進(jìn)行再次處理，便于多個流計(jì)算工程的數(shù)據(jù)共享協(xié)作。
產(chǎn)品功能
豐富的流計(jì)算插件
支持ETL處理、SQL統(tǒng)計(jì)分析、Sink類、? Source類等多類型插件，支持用戶進(jìn)行自定義插件開發(fā)，通過SDK進(jìn)行開發(fā)擴(kuò)展支持。
臨時表管理
支持用戶以寫臨時表的方式將流計(jì)算中間結(jié)果進(jìn)行緩存，供其他流計(jì)算流程作為數(shù)據(jù)源進(jìn)行再次處理。便于進(jìn)行多個流計(jì)算工程的數(shù)據(jù)共享協(xié)作。
流式表支持
支持以表的方式進(jìn)行Kafka等流式數(shù)據(jù)引擎的數(shù)據(jù)讀寫，更好的抽象底層數(shù)據(jù)，統(tǒng)一開發(fā)編程模型，支持直接利用SQL進(jìn)行全實(shí)時業(yè)務(wù)的開發(fā)和處理。
高可用支持
框架內(nèi)的處理節(jié)點(diǎn)均支持在線降級，在極端情況下保證高優(yōu)業(yè)務(wù)優(yōu)先執(zhí)行，保障實(shí)時性SLA。