统一的批处理 & 流媒体

提升用例

统一的批处理 & 流媒体

提升将批处理和流数据与单一架构进行协调,从而在使用点上不断丰富数据集. 这种统一的方法消除了对独立的基础设施和工具的需求, 从而大大节省了成本和时间.

减少代码

只需指定数据源、转换和目标. 其余的由提升来处理.

自动化

对于流架构的常见问题(i.e. 自动处理延迟数据)

减少维修

通过消除并行架构. 多花点时间建造,少花点时间修管道.

它是如何工作的

  • 直接连接到 任何流 (卡夫卡、运动等.)和提升会 自动收集 并保存数据
  • 指定流数据转换逻辑,与批处理逻辑相同 SQL、Python、Java或Scala
  • 提升自动处理和聚集新数据 时间窗口优化了微批次
  • 结合您的历史和批量数据使用时间窗口优化连接,提升确保您的 管道运行有效
  • 将结果数据直接写入数据仓库、blob存储等等

会发生什么

查看w88平台的文档以了解更多关于接收流数据的信息