- 目录 排序 默认排序 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...
- 目录 扩展阅读 关于并行度 详细讲解 关联总结 总结 在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了,赶紧手动存个档,然后接着玩,如果失败了,赶紧从上次的存档中恢复,然...
上滑加载中
推荐直播
-
华为云码道 × 仓颉编程：工程化AI编码探索2026/05/27 周三 19:00-21:00
刘俊杰-华为云仓颉语言专家/李炎-华为云码道技术专家/王智鹏-OpenCangjie开源社区发起人
本场直播围绕华为云仓颉语言与华为云码道的深度结合，展示华为云智能编程从零基础到高效落地的完整生态能力。以华为云码道为引擎，仓颉语言为载体，带给大家日常提效、趣味创新到极速量产的开发体验。
回顾中
热门标签