- 目录 Watermaker案例演示 需求 API 代码实现-1-开发版-掌握 代码实现-2-验证版-了解 Watermaker案例演示 需求 有订单数据,格式为: (订单ID，用户ID，时间戳/事件时间，订单金额) 要求每隔5s,计算5秒内，每个用户的订单总金额 并添加Watermaker来解决一定程... 目录 Watermaker案例演示 需求 API 代码实现-1-开发版-掌握 代码实现-2-验证版-了解 Watermaker案例演示 需求 有订单数据,格式为: (订单ID，用户ID，时间戳/事件时间，订单金额) 要求每隔5s,计算5秒内，每个用户的订单总金额 并添加Watermaker来解决一定程...
- 目录 方法调用方式 后缀调用法 中缀调用法 操作符即方法 花括号调用法 无括号调用法 方法调用方式 在scala中，有以下几种方法调用方式， 后缀调用法中缀调用法花括号调用法无括号调用法 在后续编写spark、flink程序时，我们会使用到这些方法调用方式。 后缀调用法 这种方法与Java没有区别... 目录 方法调用方式 后缀调用法 中缀调用法 操作符即方法 花括号调用法 无括号调用法 方法调用方式 在scala中，有以下几种方法调用方式， 后缀调用法中缀调用法花括号调用法无括号调用法 在后续编写spark、flink程序时，我们会使用到这些方法调用方式。 后缀调用法 这种方法与Java没有区别...
- 目录 样例类 定义样例类 样例类方法 样例对象 样例类 样例类是一种特殊类，它可以用来快速定义一个用于保存数据的类（类似于Java POJO类），而且它会自动生成apply方法，允许我们快速地创建样例类实例对象。后面，在并发编程和spark、flink这些框架也都会经常使用它。 定义样例类 语法结构： ... 目录 样例类 定义样例类 样例类方法 样例对象 样例类 样例类是一种特殊类，它可以用来快速定义一个用于保存数据的类（类似于Java POJO类），而且它会自动生成apply方法，允许我们快速地创建样例类实例对象。后面，在并发编程和spark、flink这些框架也都会经常使用它。 定义样例类 语法结构： ...
- 目录 总结 Flink-SQL常用算子 SELECT WHERE DISTINCT GROUP BY UNION 和 UNION ALL JOIN Group Window Tumble Window ... 目录 总结 Flink-SQL常用算子 SELECT WHERE DISTINCT GROUP BY UNION 和 UNION ALL JOIN Group Window Tumble Window ...
- 目录 Sink 预定义Sink 基于控制台和文件的Sink 自定义Sink MySQL Sink 预定义Sink 基于控制台和文件的Sink API 1.ds.print 直接输出到控制台 2.ds.printToErr() 直接输出到控制台,用红色 3.ds.... 目录 Sink 预定义Sink 基于控制台和文件的Sink 自定义Sink MySQL Sink 预定义Sink 基于控制台和文件的Sink API 1.ds.print 直接输出到控制台 2.ds.printToErr() 直接输出到控制台,用红色 3.ds....
- 条件表达式 条件表达式就是if表达式，if表达式可以根据给定的条件是否满足，根据条件的结果（真或假）决定执行对应的操作。scala条件表达式的语法和Java一样。 有返回值的if 与Java不一样的是， [!NOTE] 在scala中，条件表达式也是有返回值的在scala中，没有三元表达式，可以使用if表达式替... 条件表达式 条件表达式就是if表达式，if表达式可以根据给定的条件是否满足，根据条件的结果（真或假）决定执行对应的操作。scala条件表达式的语法和Java一样。 有返回值的if 与Java不一样的是， [!NOTE] 在scala中，条件表达式也是有返回值的在scala中，没有三元表达式，可以使用if表达式替...
- 目录 列表 List 重点掌握 不可变列表定义 可变列表 列表常用操作 列表 List 重点掌握 列表是scala中最重要的、也是最常用的数据结构。List具备以下性质： 可以保存重复的值有先后顺序 在scala中，也有两种列表，一种是不可变列表、另一种是可变列表 不可变列表定义 不可变列表就是列表的... 目录 列表 List 重点掌握 不可变列表定义 可变列表 列表常用操作 列表 List 重点掌握 列表是scala中最重要的、也是最常用的数据结构。List具备以下性质： 可以保存重复的值有先后顺序 在scala中，也有两种列表，一种是不可变列表、另一种是可变列表 不可变列表定义 不可变列表就是列表的...
- 目录 元组 重点掌握 定义元组 访问元组 元组 重点掌握 元组可以用来包含一组不同类型的值。例如：姓名，年龄，性别，出生年月。元组的元素是不可变的。 数组: 同一类数据成组 元组: 不同的元素成组 元祖内容(元素)不可变 定义元组 语法 方式1: 使用括号来定义元组 va... 目录 元组 重点掌握 定义元组 访问元组 元组 重点掌握 元组可以用来包含一组不同类型的值。例如：姓名，年龄，性别，出生年月。元组的元素是不可变的。 数组: 同一类数据成组 元组: 不同的元素成组 元祖内容(元素)不可变 定义元组 语法 方式1: 使用括号来定义元组 va...
- 目录 排序 默认排序 sorted 指定字段排序 sortBy 自定义排序 | sortWith 排序 在scala集合中，可以使用以下几种方式来进行排序 sorted默认排序sortBy指定字段排序sortWith自定义排序 默认排序 sorted 示例 定义一个... 目录 排序 默认排序 sorted 指定字段排序 sortBy 自定义排序 | sortWith 排序 在scala集合中，可以使用以下几种方式来进行排序 sorted默认排序sortBy指定字段排序sortWith自定义排序 默认排序 sorted 示例 定义一个...
- 目录 循环 for表达式 while循环 循环 在scala中，可以使用for和while，但一般推荐使用for表达式，因为for表达式语法更简洁 for表达式 语法 for(i <- 表达式/数组/集合) { // 表达式 } ... 目录 循环 for表达式 while循环 循环 在scala中，可以使用for和while，但一般推荐使用for表达式，因为for表达式语法更简洁 for表达式 语法 for(i <- 表达式/数组/集合) { // 表达式 } ...
- 目录 Connectors JDBC 代码演示 Connectors JDBC https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/connectors/jdbc.html 代码演示 package cn.itc... 目录 Connectors JDBC 代码演示 Connectors JDBC https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/connectors/jdbc.html 代码演示 package cn.itc...
- 目录 过滤 filter 定义 方法签名 方法解析 案例 参考代码 过滤 filter 过滤符合一定条件的元素 定义 方法签名 def filter(p: (A) ⇒ Boolean): TraversableOnce[A] 方... 目录 过滤 filter 定义 方法签名 方法解析 案例 参考代码 过滤 filter 过滤符合一定条件的元素 定义 方法签名 def filter(p: (A) ⇒ Boolean): TraversableOnce[A] 方...
- 目录 开发环境安装 安装JDK 安装scala SDK 步骤 具体操作 安装IDEA scala插件 步骤 开发环境安装 学习如何编写scala代码之前，需要先安装scala编译器以及开发工具 scala程序运行需要依赖于Java类库，必须要有Java运行环境，scala才能正确执行 根据前面学习的流程图，要编译... 目录 开发环境安装 安装JDK 安装scala SDK 步骤 具体操作 安装IDEA scala插件 步骤 开发环境安装 学习如何编写scala代码之前，需要先安装scala编译器以及开发工具 scala程序运行需要依赖于Java类库，必须要有Java运行环境，scala才能正确执行 根据前面学习的流程图，要编译...
- 目录 方法 定义方法 返回值类型推断 方法 一个类可以有自己的方法，scala中的方法和Java方法类似。但scala与Java定义方法的语法是不一样的。 定义方法 语法 def methodName (参数名:参数类型, 参数名:参数类型) : [return&nbs... 目录 方法 定义方法 返回值类型推断 方法 一个类可以有自己的方法，scala中的方法和Java方法类似。但scala与Java定义方法的语法是不一样的。 定义方法 语法 def methodName (参数名:参数类型, 参数名:参数类型) : [return&nbs...
- 目录 案例一 需求 代码实现 案例一 需求 将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...
上滑加载中
推荐直播
-
HDC深度解读系列 - Serverless与MCP融合创新，构建AI应用全新智能中枢2025/08/20 周三 16:30-18:00
张昆鹏 HCDG北京核心组代表
HDC2025期间，华为云展示了Serverless与MCP融合创新的解决方案，本期访谈直播，由华为云开发者专家(HCDE)兼华为云开发者社区组织HCDG北京核心组代表张鹏先生主持，华为云PaaS服务产品部 Serverless总监Ewen为大家深度解读华为云Serverless与MCP如何融合构建AI应用全新智能中枢
回顾中 -
关于RISC-V生态发展的思考2025/09/02 周二 17:00-18:00
中国科学院计算技术研究所副所长包云岗教授
中科院包云岗老师将在本次直播中，探讨处理器生态的关键要素及其联系，分享过去几年推动RISC-V生态建设实践过程中的经验与教训。
回顾中 -
一键搞定华为云万级资源，3步轻松管理企业成本2025/09/09 周二 15:00-16:00
阿言 华为云交易产品经理
本直播重点介绍如何一键续费万级资源，3步轻松管理成本，帮助提升日常管理效率！
回顾中
热门标签