- 目录 案例一 需求 代码实现 案例一 需求 将DataStream注册为Table和View并进行SQL统计 代码实现 package cn.itcast.sql; import lombok.AllArgsConstructor;import lombok.Data;imp... 目录 案例一 需求 代码实现 案例一 需求 将DataStream注册为Table和View并进行SQL统计 代码实现 package cn.itcast.sql; import lombok.AllArgsConstructor;import lombok.Data;imp...
- 目录 扩展阅读 关于并行度 详细讲解 关联总结 总结 在Flink中可以如何设置分区数/并行度? 什么时候调整并行度? 扩展阅读 关于并行度 一个Flink程序由多个Operator组成(source、transformation和 sink)。 &... 目录 扩展阅读 关于并行度 详细讲解 关联总结 总结 在Flink中可以如何设置分区数/并行度? 什么时候调整并行度? 扩展阅读 关于并行度 一个Flink程序由多个Operator组成(source、transformation和 sink)。 &...
- 目录 扩展阅读 File Sink 介绍 案例演示 扩展阅读 File Sink 介绍 https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/connectors/file_sink.html &n... 目录 扩展阅读 File Sink 介绍 案例演示 扩展阅读 File Sink 介绍 https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/connectors/file_sink.html &n...
- 目录 案例二 需求 代码实现-SQL 代码实现-Table 案例二 需求 使用SQL和Table两种方式对DataStream中的单词进行统计 代码实现-SQL package cn.itcast.sql; import lombok.AllArgsConstructor;import lombok.Data;imp... 目录 案例二 需求 代码实现-SQL 代码实现-Table 案例二 需求 使用SQL和Table两种方式对DataStream中的单词进行统计 代码实现-SQL package cn.itcast.sql; import lombok.AllArgsConstructor;import lombok.Data;imp...
- 2021大数据领域优质创作博客，带你从入门到精通，该博客每天更新，逐渐完善大数据各个知识体系的文章，帮助大家更高效学习。 有对大数据感兴趣的可以关注微信公众号：三帮大数据 目录 汇总Hadoop Hive ZooKeeper HBase Kafka等常见命令 Hadoop命令 Hive命令 ZooKeeper命... 2021大数据领域优质创作博客，带你从入门到精通，该博客每天更新，逐渐完善大数据各个知识体系的文章，帮助大家更高效学习。 有对大数据感兴趣的可以关注微信公众号：三帮大数据 目录 汇总Hadoop Hive ZooKeeper HBase Kafka等常见命令 Hadoop命令 Hive命令 ZooKeeper命...
- 目录 Spark On Hive spark-sql中集成Hive Spark代码中集成Hive Spark On Hive Spark SQL模块从发展来说，从Apache Hive框架而来，发展历程：Hive（MapReduce）-> Shark (Hive on Spark) -> Spark SQL（Sc... 目录 Spark On Hive spark-sql中集成Hive Spark代码中集成Hive Spark On Hive Spark SQL模块从发展来说，从Apache Hive框架而来，发展历程：Hive（MapReduce）-> Shark (Hive on Spark) -> Spark SQL（Sc...
- 目录 遍历 foreach 使用类型推断简化函数定义 使用下划线来简化函数定义 遍历 foreach 之前，学习过了使用for表达式来遍历集合。我们接下来将学习scala的函数式编程，使用foreach方法来进行遍历、迭代。它可以让代码更加简洁。 用途: foreach 会帮我们对集合中的每一个元... 目录 遍历 foreach 使用类型推断简化函数定义 使用下划线来简化函数定义 遍历 foreach 之前，学习过了使用for表达式来遍历集合。我们接下来将学习scala的函数式编程，使用foreach方法来进行遍历、迭代。它可以让代码更加简洁。 用途: foreach 会帮我们对集合中的每一个元...
- 目录 scala解释器 启动scala解释器 执行scala代码 退出解释器 scala解释器 后续我们会使用scala解释器来学习scala基本语法，scala解释器像Linux命令一样，执行一条代码，马上就可以让我们看到执行结果，用来测试比较方便。 我们接下来学习： 启动scala解释器在scala解释器中执行sc... 目录 scala解释器 启动scala解释器 执行scala代码 退出解释器 scala解释器 后续我们会使用scala解释器来学习scala基本语法，scala解释器像Linux命令一样，执行一条代码，马上就可以让我们看到执行结果，用来测试比较方便。 我们接下来学习： 启动scala解释器在scala解释器中执行sc...
- 目录 Savepoint Savepoint介绍 Savepoint VS Checkpoint Savepoint演示 Savepoint Savepoint介绍 Savepoint:保存点,类似于以前玩游戏的时候,遇到难关了/遇到boss了,赶紧手动存个档,然后接着玩,如果失败了,赶紧从上次的存档中恢复,然... 目录 Savepoint Savepoint介绍 Savepoint VS Checkpoint Savepoint演示 Savepoint Savepoint介绍 Savepoint:保存点,类似于以前玩游戏的时候,遇到难关了/遇到boss了,赶紧手动存个档,然后接着玩,如果失败了,赶紧从上次的存档中恢复,然...
- 目录 案例准备 依赖 程序结构 案例准备 依赖 https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/ <dependency> &... 目录 案例准备 依赖 程序结构 案例准备 依赖 https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/ <dependency> &...
- 目录 Set 不可变集 可变集 Set Set(集)是代表没有重复元素的集合。Set具备以下性质： 元素不重复 不保证插入顺序 和List正好相反, List: 元素可以重复 保证插入顺序 scala中的集也分为两种，一种是不可变集，另一种是可变集。 不可变集 定义 语法 创建一个空的不可... 目录 Set 不可变集 可变集 Set Set(集)是代表没有重复元素的集合。Set具备以下性质： 元素不重复 不保证插入顺序 和List正好相反, List: 元素可以重复 保证插入顺序 scala中的集也分为两种，一种是不可变集，另一种是可变集。 不可变集 定义 语法 创建一个空的不可...
- 背景：DSG数据同步到hadoop平台，发现部分表中数据存在竖线分隔符（“|”）,导致hadoop平台数据不准确。 为解决此问题并避免出现内容带分隔符的可能情况，商定分隔符修改为CtrlA（ascii是... 背景：DSG数据同步到hadoop平台，发现部分表中数据存在竖线分隔符（“|”）,导致hadoop平台数据不准确。 为解决此问题并避免出现内容带分隔符的可能情况，商定分隔符修改为CtrlA（ascii是...
- 文章目录 Pre Case 针对Kafka故障设计的高可用场景 无法释放的内存最终导致OOM 故障修复 Pre 之前我们已经用代码给大家都演示过... 文章目录 Pre Case 针对Kafka故障设计的高可用场景 无法释放的内存最终导致OOM 故障修复 Pre 之前我们已经用代码给大家都演示过...
- 文章目录 Pre 背景和挑战 数据治理的框架和核心内容 数据战略 组织管理 制度体系 流程管理 绩效管理 标准体系 质量体系 安全体系 平台... 文章目录 Pre 背景和挑战 数据治理的框架和核心内容 数据战略 组织管理 制度体系 流程管理 绩效管理 标准体系 质量体系 安全体系 平台...
- 1.题目：二维数组中的查找 在一个二维数组中，每一行都按照从左到右递增的顺序排序，每一列都按照从上到下递增的顺序排序。请完成一个函数，输入这样的一个二维数组和一个整数，判断数组中是否含有该整数。 解法：从二维数组的左下角开始比较，令 i = n - 1 , j = 0;(假设数组为a，i为要比较的行号，j为... 1.题目：二维数组中的查找 在一个二维数组中，每一行都按照从左到右递增的顺序排序，每一列都按照从上到下递增的顺序排序。请完成一个函数，输入这样的一个二维数组和一个整数，判断数组中是否含有该整数。 解法：从二维数组的左下角开始比较，令 i = n - 1 , j = 0;(假设数组为a，i为要比较的行号，j为...
上滑加载中
推荐直播
-
昇腾AI算法挑战赛-核心算子如何优化？专家带你深度解析2025/11/17 周一 16:00-17:00
王老师 华为算子专家
昇腾AI算法挑战赛进阶赛战鼓催征！本期直播间，我们特邀华为算子专家王老师，为你深度剖析Matmul、wholereducesum等核心算子的底层原理与优化技巧，直击赛题核心。想提升代码效率、冲击更高排名？锁定直播，带你破局！
回顾中 -
AI编码实干派，“码”力全开2026/02/26 周四 15:00-16:30
谈宗玮/于邦旭/丁俊卿/陈云亮/王一男
【中国，深圳，2026年2月26日】，以“AI编码实干派，码力全开”为主题的华为云码道（CodeArts）代码智能体新春发布会在线上成功召开。华为云码道公测版正式发布，为开发者和企业提供具备工程化能力的智能编码解决方案。
回顾中 -
华为云码道-玩转OpenClaw，开启在线养虾模式2026/03/11 周三 19:00-20:00
刘昱，华为云高级工程师/谈心，华为云技术专家/李海仑，上海圭卓智能科技有限公司CEO
OpenClaw 火爆开发者圈，华为云码道最新推出 Skill ——开发者只需输入一句口令，即可部署一个功能完整的「小龙虾」智能体。直播带你玩转华为云码道，玩转OpenClaw
回顾中
热门标签