戳更多文章:
1-Flink入门
2-本地环境搭建&构建第一个Flink应用
3-DataSet API
4-DataSteam API
5-集群部署
6-分布式缓存
7-重启策略
8-Flink中的窗口
9-Flink中的Time
Flink时间戳和水印
Broadcast广播变量
FlinkTable&SQL
Flink实战项目实时热销排行
Flink写入RedisSink
Flink消费Kafka写入Mysql
Scala 有方法与函数,二者在语义上的区别很小。Scala 方法是类的一部分,而函数是一个对象可以赋值给一个变量。换句话来说在类中定义的函数即是方法。
Scala 中的方法跟 Java 的类似,方法是组成类的一部分。
Scala 中的函数则是一个完整的对象,Scala 中的函数其实就是继承了 Trait 的类的对象。
Scala 中使用 val 语句可以定义函数,def 语句定义方法。
代码语言:javascript复制class Test{
def m(x: Int) = x 3
val f = (x: Int) => x 3
}
注意:有些翻译上函数(function)与方法(method)是没有区别的。
方法声明
Scala 方法声明格式如下:
代码语言:javascript复制def functionName ([参数列表]) : [return type]
如果你不写等于号和方法主体,那么方法会被隐式声明为抽象(abstract),包含它的类型于是也是一个抽象类型。
方法定义
方法定义由一个 def 关键字开始,紧接着是可选的参数列表,一个冒号 : 和方法的返回类型,一个等于号 = ,最后是方法的主体。
Scala 方法定义格式如下:
代码语言:javascript复制def functionName ([参数列表]) : [return type] = {
function body
return [expr]
}
以上代码中 return type 可以是任意合法的 Scala 数据类型。参数列表中的参数可以使用逗号分隔。
以下方法的功能是将两个传入的参数相加并求和:
代码语言:javascript复制object add{
def addInt( a:Int, b:Int ) : Int = {
var sum:Int = 0
sum = a b
return sum
}
}
如果方法没有返回值,可以返回为 Unit,这个类似于 Java 的 void, 实例如下:
代码语言:javascript复制object Hello{
def printMe( ) : Unit = {
println("Hello, Scala!")
}
}
方法调用
Scala 提供了多种不同的方法调用方式:
以下是调用方法的标准格式:
代码语言:javascript复制functionName( 参数列表 )
如果方法使用了实例的对象来调用,我们可以使用类似java的格式 (使用 . 号):
代码语言:javascript复制[instance.]functionName( 参数列表 )
以上实例演示了定义与调用方法的实例:
代码语言:javascript复制object Test {
def main(args: Array[String]) {
println( "Returned Value : " addInt(5,7) );
}
def addInt( a:Int, b:Int ) : Int = {
var sum:Int = 0
sum = a b
return sum
}
}
执行以上代码,输出结果为:
代码语言:javascript复制$ scalac Test.scala
$ scala Test
Returned Value : 12