尽管Scala是一种混合的面向对象和函数式编程语言，但它强调函数式编程。这就是为什么它是一种强大的语言。如果将Scala作为一种函数式编程语言使用，而不只是把它当作另一种面向对象编程语言来使...

任务要求：编写Scala 工程代码，使用Flink 消费Kafka 中dwd 层的Topic数据,表结构与离线数据表结构相同。本任务共有两个子任务组成。点击正文链接，可快速跳转到相应子任务实现部分：查看子任务...

在Scala中，Option[T]是给定类型的0或1个元素的容器。Option 是一个数据类型，用来表明一些数据的“有”或“无”，可以是Some[T]或None[T]，其中T可以是任何给定类型。一个Some 实例可以存储任...

 Scala中的String构建在Java中的String之上，并添加了额外的特性，如字符串插值（字符串插值是一种将字符串内的值与变量相结合的机制）。字符串插值是根据数据创建字符串的过程。用户可以将任...

Scala语言中提供的数组是用来存储固定大小的同类型元素的。数组的第一个元素索引为0，最后一个元素的索引为元素总数减1。Scala中数组分为定长数组和变长数组。创建定长数组Array的两种方式：先...

在本节中，我们将学习如何创建尾递归（tail recursive）函数，以及如何使用@annotation.tailrec注解，这将指示编译器应用任何进一步的优化。如何定义尾递归函数？在下面的示例中，我们定义一个...

环境说明Flink 任务在Yarn 上用per job 模式（即Job 分离模式，不采用Session 模式），方便Yarn 回收资源；建议使用gson 解析json 数据。任务描述编写Java 工程代码，使用Flink 消费Kafka 中dwd...

Scala是一种非常适合开发大数据应用程序的语言，是使用Apache Spark的首选语言。使用Scala语言来学习Spark，具有以下优点：首先，开发人员可以通过使用Scala实现显著的生产力提升。其次，它帮助...

RangeRange定义一个范围，指定开始、结束和步长，通常用于填充数据结构和遍历for循环。object RangeDemo { def main(args: Array[String]): Unit = {   // 使用方法to来创建Range(包含上限)  ...

在 Scala 中，String 是一个不可变的对象，所以该对象不可被修改。这就意味着如果修改字符串就会产生一个新的字符串对象。但其他对象，如数组就是可变的对象。字符串基本使用Scala中字符串的数...

数据存储在变量中，要对数据进行运算，就需要使用运算符。Scala语言中提供了这几种运算符：算术运算符、关系运算符、逻辑运算符、位运算符、赋值运算符等。注：实际上，Scala没有传统意义上的运...

类型化函数所谓类型化函数，指的是在调用函数时可以指定参数的类型。Scala的类型化函数通过变量的使用提供了更大的灵活性。那么，如何定义一个泛型类型函数将指定其参数的类型？下面我们将创建...

环境说明Hive 的配置文件位于主节点/opt/module/hive-3.1.2/conf/Spark 任务在Yarn 上用Client 运行，方便观察日志；ClickHouse 的jdbc 连接端口8123，用户名/密码：default/123456命令行客户端...

Scala可以安装在Windows和Linux操作系统下。下面我们分别介绍在这两个操作系统下安装Scala的步骤。 （注：在安装Scala前，请确保已经安装好了JDK 8，并配置好了环境变量。）本节包括如下内容：...

什么是向量?根据Scala文档，Vector是类似于List的数据结构。但是，它解决了List中随机访问的低效问题。【示例】学习如何使用Scala的不可变向量来执行一些常见的操作，比如初始化Vector，访问特...

在Scala中没有enum关键字。相反，Scala提供了一个Enumeration类，我们可以扩展这个类来创建枚举类型。object demo10 {​ // 创建枚举类型 object Stars extends Enumeration {   type Stars = ...