Scala wordcount

Scala wordcount

package wordcountimport org.apache.spark.SparkConfimport org.apache.spark.SparkContextimport org.apache.spark.rdd.RDDobject wordfcount { def main(args: Array[String]): Unit =……

Actor通信

Actor通信

import scala.actors.Actor/* * Actor 通信模型 * 相当于线程 *///样例类case class Message(actor:Actor,msg:String)class MyActor01 extends Actor { //接收消息 def act(): Unit = { whil……

Scala Trait

Scala Trait

trait Speak{ def speak(name:String)={ println(name+"is speak") }}trait Read{ def read(name:String)={ println(name+"is read") } }class person() extends Speak with……

Scala集合

Scala集合

object 集合 { def main(args: Array[String]): Unit = { /* * array */ val arr=Array[Int](1,2,3,4,5) arr.foreach(println) /* * List */ ……

Scala函数

Scala函数

import java.util.Dateobject fun { def main(args: Array[String]): Unit = { //函数 def max(a:Int,b:Int)={ if(a>b){ a }else{ b } ……

Scala类和对象

Scala类和对象

//创建一个类,scala的类可以传参数,有默认的构造函数,有默认的getter,setter方法class 类2(name:String){ var xname=name var gender="女" //如果一个class名称和object的名称一样,那么这个class叫做这个object的伴生类 //这个object叫做这个cl……