51dev.com IT技术开发者社区

51dev.com 技术开发者社区

【Scala】Actor并发编程实现单机版wordCount

【Scala】Actor并发编程实现单机版wordCount

文章目录对单个文本文件进行单词计数对多个文本文件进行单词计数importscala.actors.Actorimportscala.io.Source//读取文件名称样例类caseclassSubmitTask(fileName:String)classActor2WordCountextendsA...

【Scala】代码实现Scala的各种模式匹配操作

【Scala】代码实现Scala的各种模式匹配操作

文章目录内容匹配类型匹配s表达式caseclass样例类偏函数importscala.util.RandomobjectTestMatch{defmain(args:Array[String]):Unit={//创建一个Int数组valarray=Array(12,34,56,78)//随机生成数组...

【Scala】代码实现Actor多种需求

【Scala】代码实现Actor多种需求

文章目录简单实现Actor并发编程使用Actor实现发送没有返回值的异步消息使用Actor实现不间断消息发送用react方法替代receive方法接收消息结合caseclass,通过匹配不同的样例类执行不同操作importscala.actors.Actor//todo使用actor实现并发编程cl...

【Scala】isInstanceOf 与 classOf的对比,代码+注解简洁明了

【Scala】isInstanceOf 与 classOf的对比,代码+注解简洁明了

classAnimal{}classCatextendsAnimal{}objectCat{defmain(args:Array[String]):Unit={//新创建一个Cat对象valcat1:Cat=newCat//创建另一个Cat对象valcat2:Animal=newCat//因为Cat...

【Scala】scala的继承能干嘛?这段简单的代码或许能帮你梳理

【Scala】scala的继承能干嘛?这段简单的代码或许能帮你梳理

packagecn.itcast.scala.demo2classPerson{//private关键字和final关键字修饰的常量无法被继承重写valid:Int=1varname:String="zhangsan"defsayHello=println("hello")}//子类可以使用exte...

【Scala】通过简洁代码搞明白伴生关系、主构造器和辅助构造器的关系

【Scala】通过简洁代码搞明白伴生关系、主构造器和辅助构造器的关系

/***主构造器直接定义在类名称的后面,参数列表和类名写在一起*主构造器的参数会自动提升为对象的属性,不需要在对象中重新定义一遍*/classStudent(valid:Int,name:String){println("主构造器开始执行")//Student类的私有属性privatevalcity...

【Scala】看代码,初步了解Apply方法

【Scala】看代码,初步了解Apply方法

classApplyTest(valname:String){/***apply源码*defapply(x:Int,xs:Int*):Array[Int]={*valarray=newArray[Int](xs.length+1)*array(0)=x*vari=1*for(x<-xs.ite...

【Scala】关于集合的各种知识点

【Scala】关于集合的各种知识点

目录映射Map不可变Map概述操作实例可变Map概述操作实例Map的遍历for循环遍历格式操作实例模式匹配遍历格式操作实例Tuple元祖概述定义格式获取元素方法元祖遍历操作实例List列表不可变List概述相关方法相关操作操作实例可变List概述相关方法相关操作操作实例Set集合格式特点相关操作操作...

【Spark】快来学习RDD的创建以及操作方式吧!

【Spark】快来学习RDD的创建以及操作方式吧!

目录RDD的创建三种方式从一个集合中创建从文件中创建从其他的RDD转化而来RDD编程常用API算子分类Transformation概述帮助文档常用Transformation表Transformation使用实例Action帮助文档常用Action表Action使用实例三种方式从一个集合中创建val...

【Scala】新手入门,基础语法概览

【Scala】新手入门,基础语法概览

目录变量、常量和数据类型varval数据类型条件表达式块表达式to循环for循环for推导式scala中的方法和函数方法的定义函数的定义函数和方法的区别var修饰的是变量,variable,值是可变的var变量名[:变量类型]=变量值scala>varage:Int=23age:Int=23s...

【Spark】RDD(Resilient Distributed Dataset)究竟是什么?

【Spark】RDD(Resilient Distributed Dataset)究竟是什么?

目录基本概念官方文档概述含义RDD出现的原因五大属性以单词统计为例,一张图熟悉RDD当中的五大属性解构图RDD弹性RDD特点分区只读依赖缓存checkpoint基本概念官方文档介绍RDD的官方说明:http://spark.apache.org/docs/latest/rdd-programming...

【Spark】Spark-shell案例——standAlone模式下读取HDFS上存放的文件

【Spark】Spark-shell案例——standAlone模式下读取HDFS上存放的文件

目录可以先用local模式读取一下步骤一、先将做测试的数据上传到HDFS二、开发scala代码standAlone模式查看HDFS上的文件步骤一、退出local模式,重新进入Spark-shell二、开发scala代码可以先用local模式读取一下步骤一、先将做测试的数据上传到HDFScd/expo...

【Spark】使用java语言开发spark程序

【Spark】使用java语言开发spark程序

目录步骤一、创建maven工程,导入jar包二、开发代码步骤一、创建maven工程,导入jar包<properties><scala.version>2.11.8</scala.version><spark.version>2.2.0</spar...

【Spark】Spark-shell案例——单词计数统计

【Spark】Spark-shell案例——单词计数统计

目录步骤一、准备本地文件以作测试二、通过--master启动本地模式三、开发scala单词统计代码步骤一、准备本地文件以作测试在第一台机器执行mkdir-p/export/servers/sparkdatascd/export/servers/sparkdatas/vimwordcount.txth...

【Spark】不熟悉Spark-shell常用参数?这一张图就够了

【Spark】不熟悉Spark-shell常用参数?这一张图就够了

...