错误1.错误: 找不到或无法加载主类 idea、scala代码 idea 导入的scala工程，编写代码后报该错误。 原因：\src\main\scala 包路径下没有将scala这个包设置成Sources root 解决：设置scala的文件夹属性 错误2. ERROR scheduler.Liv ...
分类：
其他好文 时间：
2019-12-11 19:34:16
阅读次数：
193
val rdd= sc.parallelize(List(("tom",1),("jerry",3),("kitty",2),("tom",2))) //1.根据传入的参数进行分组 val rdd1:RDD[(String, Iterable[(String, Int)])] =rdd.groupB ...
分类：
其他好文 时间：
2019-12-10 19:45:36
阅读次数：
110
前言Kafka是最初由Linkedin公司开发，是一个分布式、支持分区的（partition）、多副本的（replica），基于zookeeper协调的分布式消息系统，它的最大的特性就是可以实时的处理大量数据以满足各种需求场景：比如基于hadoop的批处理系统、低延迟的实时系统、storm/Spark流式处理引擎，web/nginx日志、访问日志，消息服务等等，用scala语言编写，Linkedi
分类：
其他好文 时间：
2019-12-09 18:50:02
阅读次数：
101
一：类型参数 泛型类 //泛型类，基本和java是一致的 class Pair[T,S](val first:T,val second:S) val pair1 = new Pair("42",42) val pair2 = new Pair[Any,Any](42,"42") 泛型函数 //返回数 ...
分类：
其他好文 时间：
2019-12-08 12:41:21
阅读次数：
130
练习1 编写computer类，包含CPU、内存、硬盘等属性，getDetails方法用于返回computer的详细信息。 编写PC子类，继承computer类，添加特有属性【品牌brand】 编写notepad类，继承computer类，添加特有属性【颜色color】 编写test object， ...
分类：
其他好文 时间：
2019-12-07 01:29:23
阅读次数：
210
函数可以没有返回值案例，编写一个函数，从终端输入一个整数，打印出对应的金字塔 import scala.io.StdIn object work02 { def main(args: Array[String]): Unit = { println("请输入一个数") var num:Int=Std ...
分类：
其他好文 时间：
2019-12-07 01:21:53
阅读次数：
203
import util.control.Breaks._ object work01 { def main(args: Array[String]): Unit = { //方式一 var sum:Int= 0 breakable{ for (i<-1 to 100){ sum =sum+i if ...
分类：
其他好文 时间：
2019-12-07 01:11:14
阅读次数：
225
练习2：根据下图实现类。在TestCylinder类中创建Cylinder类的对象，设置圆柱的底面半径和高，并输出圆柱的体积 ...
分类：
其他好文 时间：
2019-12-07 01:05:58
阅读次数：
110
1.先要区分是Java中哪个版本的接口,因为Java中不同版本接口是不一样2.Java8之前的接口(不包含Java8),这个版本的接口只能属性和抽象方法,和Scala中的特质有完全的不用因为Scala特质除了定义属性和抽象方法之外,还可以定实现方法和抽象属性3.Java8之后的接口(包含Java8) ...
分类：
编程语言 时间：
2019-12-06 21:20:28
阅读次数：
125
①下载flink-1.7.2-bin-hadoop27-scala_2.11.tgz，解压后进入bin，双击：start-cluster.bat（Windows环境）。 然后打开7777端口： ②进入http://localhost:8081，界面如下： ③ ④ ⑤点击Submit ⑥结果 如下界面 ...
分类：
Web程序 时间：
2019-12-06 19:14:26
阅读次数：
238
