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

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

任务描述编写Scala 工程代码， 将MySQL 的ds_db01 库中表order_master、order_detail、coupon_info、coupon_use、product_browse、product_info、customer_inf 、customer_login_log 、order_ca...

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

转义字符在Scala中，也支持如下的转义字符：FF转义字符Unicod编码说明\b\u0008退格(BS)，将当前位置移到前一列\t\u0009水平制表(HT)，跳到下一个TAB位置\n\u000a换行(LF)，将当前位置移到下一行...

字符串中正则表达式模式匹配通过在String上调用.r方法来创建一个scala.util.matching.Regex对象，然后在findFirstIn中使用该模式来查找一个匹配，在findAllIn中使用该模式来查找所有的匹配。  ...

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

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

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

在Scala中，可以通过编写隐式转换，并在需要时将它们引入作用域，从而向封闭类添加新功能。这种方法的一个主要好处是，不必扩展现有的类来添加新功能。从Scala 2.10开始，可以定义一个隐式类，...

在前面的章节已经讲了Scala中的简单模式匹配。模式匹配是一个表达式，因此它会导致一个值，该值可能被分配或返回。例如：44 match {   case 44 => true     // 如果匹配了44,则结果为true...

Scala中提供了一种特殊的类，用case class进行声明，中文也可以称作“样例类”。样例类是一种特殊的类，经过优化以用于模式匹配。样例类类似于常规类，带有一个case 修饰符的类，在构建不可变类...

Scala做了一些面向对象的创新，其中之一就是特质(Trait)。trait类似于带有部分实现的抽象类。一个特质（trait）代表一个接口，由相关类的层级所支持。它是一个抽象机制，帮助开发模块化、可重用...

类的继承继承是一种描述类与类之间的关系，反映的是“is a”这种关系。子类通过关键字extends继承了父类的字段和方法，同时可以自定义相应的字段和方法。需要注意的是，如果父类中的成员，包括...

 单例对象在面向对象编程中一个常见的设计模式是定义一个只能被实例化一次的类。一个只能被实例化一次的类叫做“单例(singleton)”。Scala不提供任何静态修饰符，这与构建纯面向对象语言的设计...

类是一个面向对象编程概念，提供了一个高级编程抽象。从本质上来说，类是代码组织技术，将数据和所有数据的操作绑定在一起。从概念上来说，类代表一个属性和行为的实体。类是在运行时创建对象的...