zoukankan      html  css  js  c++  java
  • flink的流处理特性

    flink的流处理特性:

    支持高吞吐、低延迟、高性能的流处理

    支持带有事件时间的窗口(Window)操作

    支持有状态计算的Exactly-once语义

    支持高度灵活的窗口(Window)操作,支持基于time、count、session,以及data-driven的窗口操作

    支持具有Backpressure功能的持续流模型

    支持基于轻量级分布式快照(Snapshot)实现的容错

    一个运行时同时支持Batch on Streaming处理和Streaming处理

    Flink在JVM内部实现了自己的内存管理

    支持迭代计算

    支持程序自动优化:避免特定情况下Shuffle、排序等昂贵操作,中间结果有必要进行缓存

    API支持

    对Streaming数据类应用,提供DataStream API

    对批处理类应用,提供DataSet API(支持Java/Scala)

    Libraries支持

    支持机器学习(FlinkML)

    支持图分析(Gelly)

    支持关系数据处理(Table)

    支持复杂事件处理(CEP)

    整合支持

    支持Flink on YARN

    支持HDFS

    支持来自Kafka的输入数据

    支持Apache HBase

    支持Hadoop程序

    支持Tachyon

    支持ElasticSearch

    支持RabbitMQ

    支持Apache Storm

    支持S3

    支持XtreemFS

     

  • 相关阅读:
    Linux异步IO
    基本数据类型总结--
    总结
    字典魔法二
    字典及其魔法
    元祖的魔法
    列表的特点
    运算符
    while ……else……和while……continue……和 while…………break…………
    作业---写一个程序,用户名 、密码输入错误3次 错误
  • 原文地址:https://www.cnblogs.com/niutao/p/10548232.html
Copyright © 2011-2022 走看看