flink推荐系统

eye 2023年09月06日 61次浏览

flink推荐系统


Apache Flink 是一个开源流处理框架,具有强大的流处理和批处理能力。

特性

  • 支持批处理和数据流程序的流优先运行时
  • Java 和 Scala 中优雅流畅的 API
  • 同时支持极高吞吐量和低事件延迟的运行时
  • 基于数据流模型,支持DataStream API 中的事件时间和无序处理
  • 跨不同时间语义(事件时间、处理时间)的灵活窗口(时间、计数、会话、自定义触发器)
  • 具有一次性处理保证的容错能力
  • 流媒体程序中的自然背压
  • 用于图形处理(批处理)、机器学习(批处理)和复杂事件处理(流式处理)的库
  • DataSet(批处理)API 中对迭代程序 (BSP) 的内置支持
  • 自定义内存管理,可在内存和核外数据处理算法之间进行高效、稳健的切换
  • Apache Hadoop MapReduce 的兼容层
  • 与 YARN、HDFS、HBase 和 Apache Hadoop 生态系统的其他组件集成