在之前的文章中，我们学习了如何在scala中定义与使用集合和元组。想了解的朋友可以查看这篇文章。同时，希望我的文章能帮助到你，如果觉得我的文章写的不错，请留下你宝贵的点赞，谢谢。

Spark-Scala语言实战（4）-CSDN博客https://blog.csdn.net/qq_49513817/article/details/136881756?spm=1001.2014.3001.5501

目录

一、知识回顾

二、Scala类与对象

1.类（Class）和对象（Object）

Person类：

PersonApp对象：

2.构造器（Constructor）

PersonApp对象：

局部类Person：

对象创建和方法调用：

3.伴生对象（Companion Objects）

三、例题演练

 1、定义一个高阶函数

2、定义一个高阶函数

3、对数据中的元素按照指定规则进行分组

4、根据指定规则对数组所有元素聚合

拓展-类和对象

---

一、知识回顾

 在上一篇函数中，我们学习了集合，创建集合的方法有三种，分别是List、Set和map

 

 

 而我们的元组，则不需要用特殊的关键字，可以直接创建

 现在，开始今天的学习吧

二、Scala类与对象

1.类（Class）和对象（Object）

 类定义了对象的属性和方法。在Scala中，我们可以使用class关键字来定义一个类。而对象是类的实例，我们可以使用new关键字来创建类的对象。

例：

package com.tipdm.scalaDemoobject PersonApp {def main(args: Array[String]): Unit = {// 创建Person对象val peng = new Person// 设置属性peng.name = "peng"peng.age = 18// 调用方法peng.introduce()  // 应该输出: Hello, my name is peng and I am 18 years old.}
}class Person {var name: String = _var age: Int = _def introduce(): Unit = {println(s"Hello, my name is $name and I am $age years old.")}
}

在我的代码中，我运用到了：

1. Person类：

   • 定义了一个名为Person的类。
   • 类中有两个变量（属性）：name（表示人的名字）和age（表示人的年龄）。这两个变量都被初始化为占位符_，表示它们可以在创建对象后被赋予具体的值。
   • 类中定义了一个方法introduce，这个方法没有参数，返回类型为Unit（相当于Java中的void）。当调用这个方法时，它会打印出一条包含name和age属性值的问候信息。

2. PersonApp对象：

   • 定义了一个名为PersonApp的单例对象。在Scala中，单例对象类似于Java中的静态类或单例类，用于包含程序的入口点或其他共享功能。
   • PersonApp对象中包含一个main方法，这是Scala应用程序的入口点。当你运行Scala程序时，JVM会调用这个main方法开始执行程序。
   • 在main方法中，首先创建了一个Person类的实例peng。
   • 然后，通过peng对象设置了name属性为"peng"和age属性为18。
   • 最后，调用了peng对象的introduce方法，该方法会打印出一条问候信息，内容应该是：“Hello, my name is peng and I am 18 years old.”。

看一下输出吧

2.构造器（Constructor）

 Scala的类可以有一个或多个构造器，它们用于初始化对象的属性。在Scala中，主构造器的参数直接定义在类定义中，而辅助构造器使用this关键字来调用。

package com.tipdm.scalaDemoobject PersonApp {def main(args: Array[String]): Unit = {class Person(val name: String, val age: Int) {def introduce(): Unit = {println(s"Hello, my name is $name and I am $age years old.")}}val bob = new Person("peng", 18)bob.introduce() // 输出: Hello, my name is peng and I am 18 years old.}
}

在以上代码中，我的方法是：

1. PersonApp对象：

   • 定义了一个名为PersonApp的单例对象，它是程序的入口点。
   • 在PersonApp对象内部定义了main方法，这是Scala应用程序的入口点。

2. 局部类Person：

   • 在main方法内部定义了一个局部类Person。这个类接受两个参数：name（表示人的名字）和age（表示人的年龄）。这两个参数被声明为val，意味着它们是不可变的，并且在对象创建时就需要被初始化。
   • 类中定义了一个方法introduce，用于打印出一条包含name和age属性值的问候信息。

3. 对象创建和方法调用：

   • 在main方法中，创建了一个Person类的实例bob，并传入了名字"peng"和年龄18作为构造参数。
   • 接着调用了bob对象的introduce方法，该方法会打印出一条问候信息。

3.伴生对象（Companion Objects）

 在Scala中，每个类都有一个与之关联的伴生对象。这个对象与类共享相同的名称，并且它的定义位于类定义的外部。伴生对象可以包含静态方法或字段，这些方法和字段可以通过类名直接访问。

package com.tipdm.scalaDemoobject PersonApp {object PersonUtils {def greet(name: String): Unit = {println(s"Hello, $name!")}}class Person(val name: String) {def introduce(): Unit = {println(s"My name is $name.")}}
}object Main {def main(args: Array[String]): Unit = {PersonApp.PersonUtils.greet("peng") //val charlie = new PersonApp.Person("peng")charlie.introduce()}
}

看下输出：

三、例题演练

 1、定义一个高阶函数（1

按照指定的规则对集合里面的每个元素进行操作 比如: Array(“hh”,“red”,“java”,“hadoop”) 规则: 对集合中每个元素进行操作，得到集合每个元素的长度

package com.tipdm.scalaDemoobject p6 {def main(args: Array[String]): Unit = {def ppp(arr: Array[String]): Array[Int] = {arr.map(element => element.length)}val array = Array("hh", "red", "java", "hadoop")val lengths = ppp(array)val p = lengths.toList // 将数组转换为列表println(p) // 输出: List(2, 3, 4, 6)}
}

 

2、定义一个高阶函数（2

对数据中的元素按照指定的规则进行过滤 比如: Array(1,4,7,9,10,6,8,99,88,66) 规则: 只保留偶数数据

package com.tipdm.scalaDemoobject p6 {def main(args: Array[String]): Unit = {def peng(arr: Array[Int]): Array[Int] = {arr.filter(number => number % 2 == 0)}val numbers = Array(1, 4, 7, 9, 10, 6, 8, 99, 88, 66)val ppp = peng(numbers)val p1 = ppp.toList // 将数组转换为列表println(p1) // 输出: List(4, 10, 6, 88, 66)}
}

 

3、对数据中的元素按照指定规则进行分组

比如:Array(“zhangsan shenzhen man”,“lisi beijing woman”,“zhaoliu beijing man”) 规则: 按照地址进行分组

package com.tipdm.scalaDemoobject p6 {def main(args: Array[String]): Unit = {def p1(arr: Array[String]): Map[String, List[String]] = {arr.groupBy(person => person.split(" ")(1)).mapValues(_.toList) // 将每个地址对应的数组转换为列表}val people = Array("zhangsan shenzhen man", "lisi beijing woman", "zhaoliu beijing man")val newp1 = p1(people)println(newp1)}
}

.mapValues(_.toList): 由于groupBy返回的映射的值是数组，所以这里使用mapValues方法来转换这些数组为列表。_.toList是一个简短的lambda表达式，它接受一个数组并返回该数组的列表形式。

4、根据指定规则对数组所有元素聚合

比如:Array(10,4,6,10,2) 规则: 求和/求乘积

求和
package com.tipdm.scalaDemoobject p6 {def main(args: Array[String]): Unit = {def peng(arr: Array[Int]): Int = {arr.sum}val pp = Array(10, 4, 6, 10, 2)val sum = peng(pp)println(sum) // 输出: 32}
}求乘积
package com.tipdm.scalaDemoobject p6 {def main(args: Array[String]): Unit = {def peng(arr: Array[Int]): Int = {arr.product}val pp = Array(10, 4, 6, 10, 2)val product = peng(pp)println(product) // 输出: 4800}
}

拓展-类和对象

示例

方法名称	描述
__init__	构造函数，用于初始化对象的状态。在创建对象时自动调用。
get_attribute	获取对象的某个属性值。
set_attribute	设置对象的某个属性值。
do_action	执行某个操作或任务，可能涉及修改对象的状态或与其他对象交互。
is_condition_met	检查对象的某个条件是否满足，并返回布尔值。
calculate_result	执行计算并返回结果。
compare_to	将当前对象与另一个对象进行比较，并返回比较结果。
to_string	将对象转换为字符串表示形式。