豐富的流計(jì)算插件
支持ETL處理、SQL統(tǒng)計(jì)分析、Sink類(lèi)、? Source類(lèi)等多類(lèi)型插件,支持用戶(hù)進(jìn)行自定義插件開(kāi)發(fā),通過(guò)SDK進(jìn)行開(kāi)發(fā)擴(kuò)展支持。
臨時(shí)表管理
支持用戶(hù)以寫(xiě)臨時(shí)表的方式將流計(jì)算中間結(jié)果進(jìn)行緩存,供其他流計(jì)算流程作為數(shù)據(jù)源進(jìn)行再次處理。便于進(jìn)行多個(gè)流計(jì)算工程的數(shù)據(jù)共享協(xié)作。
流式表支持
支持以表的方式進(jìn)行Kafka等流式數(shù)據(jù)引擎的數(shù)據(jù)讀寫(xiě),更好的抽象底層數(shù)據(jù),統(tǒng)一開(kāi)發(fā)編程模型,支持直接利用SQL進(jìn)行全實(shí)時(shí)業(yè)務(wù)的開(kāi)發(fā)和處理。
高可用支持
框架內(nèi)的處理節(jié)點(diǎn)均支持在線降級(jí),在極端情況下保證高優(yōu)業(yè)務(wù)優(yōu)先執(zhí)行,保障實(shí)時(shí)性SLA。