思维导图备注

Apache Flink 1.7-SNAPSHOT 中文文档
首页 白天 夜间 BookChat 小程序 小程序 阅读
  • 书签 我的书签
  • 添加书签 添加书签 移除书签 移除书签

算子

 来源:sojb.cn 浏览 639 扫码 分享 2019-10-13 10:35:55
    • 概览
    • 窗口
    • 关联
    • 处理函数
    • 异步I/O
    当前内容版权归 sojb.cn 或其关联方所有，如需对内容或内容相关联开源项目进行关注与资助，请访问 sojb.cn .
    上一篇:
    下一篇:
    • 书签
    • 添加书签 移除书签
    • 首页
    • 概念
      • 编程模型
      • 分布式运行时
    • 教程
      • API 教程
        • DataStream
      • Setup 教程
        • 本地设置
        • Windows上运行Flink
    • 例子
      • 概览
      • 批处理例子
    • 应用开发
      • 项目构建设置
        • Java项目模板
        • Scala项目模板
        • 依赖、连接器、类库的配置
      • 基础 API 概念
        • 概览
        • ScalaAPI 扩展
        • JavaLambda表达式
      • 流式传输 (DataStream API)
        • 概览
        • 事件时间
          • 概览
          • 生成时间戳 / 水印
          • 预定义Timestamp提取器/ Watermark发射器
        • 状态 & 容错
          • 概览
          • 状态抽象原理
          • 广播状态模式
          • 检查点机制
          • 可查询状态
          • 状态后台处理
          • 自定义序列化
        • 算子
          • 概览
          • 窗口
          • 关联
          • 处理函数
          • 异步I/O
        • 连接器
          • 概览
          • 容错性保证
          • Kafka
          • Cassandra
          • Kinesis
          • Elasticsearch
          • 滚动文件接收器
          • 流文件接收器
          • RabbitMQ
          • NiFi
          • Twitter
        • 旁路输出
        • Python
        • 测试
        • 实验特征
      • 批处理 (DataSet API)
        • 概览
        • 转换
        • 容错
        • 数据压缩
        • 迭代
        • Python
        • 连接器
        • Hadoop兼容性
        • 本地执行
        • 集群运行
      • Table API & SQL
        • 概览
        • 概念 & 普通API
        • 流处理概念
        • 连接外部系统
        • Table
        • SQL
        • 内建函数
        • 自定义Sources & Sinks
        • 自定义函数
        • SQL
      • 数据类型 & 序列化
        • 概览
        • 自定义序列化器
      • 管理执行
        • 执行配置
        • 程序打包
        • 并行执行
        • 执行计划
        • 重启策略
      • 类库
        • 事件处理(CEP)
        • Storm兼容适配
        • 图计算: Gelly
          • 概览
          • 图计算
          • 迭代图计算处理
          • 方法库
          • 图计算算法
          • 图生成器
          • 双向图
        • 机器学习
          • 概览
          • 快速开始
          • 如何贡献
          • 交叉验证
          • 距离指标
          • k-NearestNeighbors Join
          • MinMax
          • 多元线性回归
          • 管道
          • 多项式特征
          • 随机离群点选择
          • 标准尺度
          • ALS
          • SVM使用 CoCoA
      • 最佳实践
      • API 迁移指南
    • 部署和运营
      • 集群 & 部署
        • 独立集群
        • YARN
        • Mesos
        • Kubernetes
        • Docker
        • AWS
        • GoogleCompute Engine
        • MapR
        • Hadoop集成
      • 高可用性(HA)
      • 状态 & 容错
        • 检查点
        • 保存点
        • 状态后台
        • 检查点与大状态调整
      • 配置
      • 生产准备清单
      • CLI
      • Scala REPL
      • Kerberos
      • SSL 设置
      • 文件系统
      • 升级应用程序和Flink版本
    • 调试和监控
      • 指标
      • 日志
      • 历史服务器
      • 监控检查点
      • 背压监测
      • 监控 REST API
      • 调试窗口 &事件时间
      • 调试类加载
      • 应用程序分析
    • FlinkDevelopment
      • 导入 Flink 到 IDE
      • 从源码构建 Flink
    • 内幕
      • 组件堆栈
      • 数据流容错性
      • 作业调度
      • 任务生命周期
      • 文件系统
    暂无相关搜索结果！

      本文档使用 BookStack 构建

      展开/收起文章目录

      分享，让知识传承更久远

      文章二维码

      手机扫一扫，轻松掌上读

      文档下载

      • 普通下载
      • 下载码下载(免登录无限下载)
      你与大神的距离，只差一个APP
      APP下载
      请下载您需要的格式的文档，随时随地，享受汲取知识的乐趣！
      PDF文档 EPUB文档 MOBI文档
      温馨提示 每天每在网站阅读学习一分钟时长可下载一本电子书，每天连续签到可增加阅读时长
      下载码方式下载：免费、免登录、无限制。 免费获取下载码

      微信小程序阅读

      BookChat 微信小程序阅读
      您与他人的薪资差距，只差一个随时随地学习的小程序

      书签列表

        阅读记录

        阅读进度: 0.00% ( 0/0 ) 重置阅读进度