前言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
<dependencies> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-scala_2.11</artifactId> <version>1.7.2</version> </dependency> <depe ...
分类：
其他好文 时间：
2019-12-06 12:03:37
阅读次数：
268
1：软件是idea，在同一个包中，类名一样，会导致在调用类的时候，程序无法找到正确的类，最后出错。 2：return坑，在方法中，返回值的类型已经指定了，所以可以放心使用return，但是在函数中，没有指定返回值的类型，一旦使用return，scala就推断不出返回值的类型了，函数会将最后一行作为返 ...
分类：
其他好文 时间：
2019-12-05 19:12:32
阅读次数：
90
