大数据

白天 夜间 首页 下载 阅读记录
  我的书签   添加书签   移除书签

Flink Transform

浏览 156 扫码 分享 2023-11-13 09:39:52

    算子用法包括:Map / FlatMap / Filter / KeyBy / Reduce / Fold / Aggregations / Split、Select
    https://github.com/Wells-Lee/flink-demo/tree/master/src/main/java/com/wells/flink/demo/api/transform

    若有收获,就点个赞吧

    0 人点赞

    上一篇:
    下一篇:
    • 书签
    • 添加书签 移除书签
    • 大数据学习路线图
    • Hadoop体系
      • Hadoop Common
        • 一、Hadoop简介
        • 二、Hadoop之常用命令
        • 三、Hadoop架构模型
        • 四、Hadoop3.0开篇介绍
        • 五、环境搭建
          • 公共环境搭建
            • Linux服务器之间配置免密登录
            • zk集群搭建
          • 5.1、伪分布式安装
            • Hadoop2.9.1
          • 5.2、全分布式安装
            • Hadoop3.1.1
          • 5.3、HA高可用搭建
            • Hadoop 3.1.2
            • hadoop 2.8.5
        • 浅谈SecondaryNameNode和NameNode
        • 联邦federation
      • HDFS
        • 一、HDFS概述
        • 二、HDFS的shell操作
        • 三、HDFS API操作
        • 四、HDFS IO操作
        • 五、HDFS的数据流(面试重点)
        • 六、NameNode相关
          • 一、NameNode和SecondNameNode(面试开发重点)
          • 二、存储模型(HDFS)
          • 三、Block的副本放置策略
          • 四、集群安全模式
          • 五、NameNode 多目录配置
        • 七、DataNode相关
          • 一、DataNode核心
        • 八、HDFS 2.X新特性
      • MapReduce
        • 一、MapReduce概述
        • 二、MR案例
        • 三、Hadoop序列化
        • 四、MapReduce框架原理(上)
        • 五、MapReduce框架原理(中)
        • 六、MapReduce框架原理(下)
        • 七、MapReduce分阶段解析
        • 八、Join & 计数器
        • 九、MapReduce开发总结
        • 十、Hadoop数据压缩
        • 十一、YARN资源调度器
        • 十二、Hadoop优化
      • Hadoop YARN
        • 第一章:环境准备
        • 第二章:Yarn的设计理念与基本架构
        • 第三章:Yarn基础库
          • Hadoop RPC
        • YARN详解
      • Hive
        • HiveSQL基本操作
      • HBase
        • HBase简介
        • HBase架构
        • HBase环境搭建
          • HBase单机模式搭建
          • HBase全分布式搭建
        • HBase使用
          • HBase Shell
          • HBase数据结构
          • HBase API操作
        • HBase原理
          • HBase读数据流程
          • HBase写数据流程
          • Flush和Compact过程
          • HBase原理和设计
        • HBase优化
        • BulkLoad
          • MR BulkLoad入库HBase
          • Spark BulkLoad入库HBase
    • Spark体系
      • SparkCore
        • Spark思维导图
        • Spark相对于MapReduce的优势
        • Spark编程指南
        • 第一章:RDD概述
        • 第二章:RDD编程
        • 第三章:Spark算子
          • Spark算子详解(上)
          • Spark算子详解(中)
          • Spark算子详解(下)
        • 第四章:RDD依赖关系
          • RDD依赖关系
        • 第五章:RDD缓存
          • RDD缓存
          • CheckPoint
        • 第六章:RDD分区
          • 键值对RDD数据分区
        • 第七章:数据读取与保存
          • 数据读取与保存
        • 第八章:RDD编程进阶
          • RDD编程进阶
        • 第九章:Spark内核
          • Spark内核概述
          • Spark on Yarn Cluster 任务部署流程
          • Spark框架组件 & 通信
          • SparkContext解析
          • 任务的划分 & 调度 & 执行
          • Spark shuffle解析
          • Spark内存管理
          • Spark 核心组件解析
        • 第十章:Spark性能调优
      • SparkSQL
        • 第一章:SparkSQL概述
        • 第二章:SparkSQL编程
          • SparkSQL编程(上)
          • SparkSQL编程(下)
      • SparkStreaming
        • SparkStreaming内容
        • 反压(Back Pressure)机制介绍
        • SparkStreaming Kafka
    • Flink
      • Flink简介
      • Flink部署
      • Flink运行架构
      • Flink流处理API
        • DataSource介绍
        • Flink Transform
        • Data Sink介绍
        • Time And Window (一)
        • Time And Window (二)
      • Flink底层API
      • Flink状态管理
      • Flink 容错机制
      • Flink状态一致性
      • Table API 与 SQL
    • kafka
      • 【Kafka】第一篇:Kafka概述
      • 【Kafka】第二篇:Kafka入门
      • 【Kafka】第三篇:Kafka核心知识点概览
      • kafka基本概念
    • Azkaban
      • 概述
    • Greenplum
      • GP常用函数和命令
      • 需要掌握的点
    • Elasticsearch
      • 【Elasticsearch实践】(一)Elasticsearch架构
      • 【Elasticsearch实践】(二)Elasticsearch部署
      • 【Elasticsearch实践】(四)IK分词器插件
      • 【Elasticsearch实践】(五)ES搜索
      • 【Elasticsearch实践】(六)ES搜索
      • 【Elasticsearch实践】(七)ES聚合搜索
      • 【Elasticsearch实践】Elasticsearch为什么这么快
    • 疑难杂症
      • 记录一次阅读MR源码解决问题的经历
      • 细品数据倾斜
      • MapReducer中获取输入文件路径
    暂无相关搜索结果!

      让时间为你证明

      展开/收起文章目录

      分享,让知识传承更久远

      文章二维码

      手机扫一扫,轻松掌上读

      文档下载

      请下载您需要的格式的文档,随时随地,享受汲取知识的乐趣!
      PDF文档 EPUB文档 MOBI文档

      书签列表

        阅读记录

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

          思维导图备注