提供全可視化、簡單易用、高吞吐量、高容錯、一站式流數據計算處理平臺,支持SQL進行實時數據清洗、數據分析、數據同步,全面的監控機制,保證流式計算的準確性。可支撐企業實時數倉構建、實時數據大屏、實時報表等企業各類實時數據處理場景的應用。
強大的實時處理能力
任務作業支持百萬級吞吐,秒級延遲,自動處理容錯,做到高可用,單個集群可達到數據千臺規模
數據安全
完善的消息追蹤框架和復雜的事務性處理,保證數據計算不重復不丟失
一站式托管服務能力
一站式全托管的流式數據處理能力,支持全鏈路的流式數據計算和任務健康度的監控與預警
豐富靈活
提供SQL和上傳JAR方式進行作業的開發;提供自定UDF函數功能,支持集群任務資源橫向和縱向配置調整
簡單易用
提供SQL語義的數據分析處理能力,降低流數據的分析處理門檻
全面監控
提供全面的任務運維監控功能,對任務的健康狀態進行及時預警和調整
支持Flink SQL關鍵字自動識別,數據預覽、一鍵引用數據源等輔助編譯功能,支持代碼版本回滾、自定義UDF函數、自動識別代碼結構、提供作業單機數據調試功能,在線查看調試結果和運行日志,避免影響線上數據。

提供全部的作業運行信息監控,通過程序的Task運行狀態和拓撲圖分析、輔助工程師及時判斷作業的健康狀態并進行調優操作。

實時計算平臺提供豐富的Kafka集群數據監控,包括集群監控大屏、主題管理、消費者應用、集群監控和告警功能等,幫助管理者監控和管理Kafka的動態,對消費者應用數據積壓情況進行及時告警。

攜手科杰科技,構建AI-Native時代 Data&AI 一體化平臺