scala

Scala中的IO操作及ArrayBuffer线程安全问题
日志通过Scala对文件进行读写操作在实际业务中应用也比较多,这里介绍几种常用的方式,直接上代码: 1. 从文件中读取内容 object Main { def loadData(): Array[Stri ...
1
学好Spark/Kafka必须要掌握的Scala技术点(二)类、单例/伴生对象、继承和trait,模式匹配、样例类(case class)
日志3. 类.对象.继承和trait 3.1 类 3.1.1 类的定义 Scala中,可以在类中定义类.以在函数中定义函数.可以在类中定义object:可以在函数中定义类,类成员的缺省访问级别是:publ ...
1
学好Spark/Kafka必须要掌握的Scala技术点(一)变量、表达式、循环、Option、方法和函数,数组、映射、元组、集合
日志前言 Scala是以JVM为运行环境的面向对象的函数式编程语言,它可以直接访问Java类库并且与Java框架进行交互操作.正如之前所介绍,Spark是用Scala语言编写的,Kafka server端 ...
1
Scala编程 笔记
日志date: 2019-08-07 11:15:00 updated: 2019-11-25 20:00:00 Scala编程 笔记 1. makeRDD 和 parallelize 生成 RDD de ...
1
Scala 特殊符号含义
日志date: 2019-08-01 11:15:27 updated: 2019-08-22 15:22:32 Scala 特殊符号含义 参考地址 1. ::: :::(三个冒号)只用于连接两个 Lis ...
1
akka-streams - 从应用角度学习:basic stream parts
日志   实际上很早就写了一系列关于akka-streams的博客.但那个时候纯粹是为了了解akka而去学习的,主要是从了解akka-streams的原理为出发点.因为akka-streams是akka系 ...
1
akka-grpc - 应用案例
日志  上期说道:http/2还属于一种不算普及的技术协议,可能目前只适合用于内部系统集成,现在开始大面积介入可能为时尚早.不过有些项目需求不等人,需要使用这项技术,所以研究了一下akka-grpc,写了 ...
1
akka-grpc - 基于akka-http和akka-streams的scala gRPC开发工具
日志 关于grpc,在前面的scalaPB讨论里已经做了详细的介绍:google gRPC是一种全新的RPC框架,在开源前一直是google内部使用的集成工具.gRPC支持通过http/2实现protob ...
2
akka-typed(10) - event-sourcing, CQRS实战
日志在前面的的讨论里已经介绍了CQRS读写分离模式的一些原理和在akka-typed应用中的实现方式.通过一段时间akka-typed的具体使用对一些经典akka应用的迁移升级,感觉最深的是EvenSou ...
1
scala 循环中continue和break
日志1. continue import scala.util.control.Breaks._ for(){ breakable{ if(){ break // continue } } } 2.bre ...
2
scala集合-collection
日志参考:https://www.jianshu.com/p/69bff3c7ec97 Scala的集合类可以从三个维度进行切分: 可变与不可变集合(Immutable and mutable colle ...
1
scala集合-List
日志参考:https://www.runoob.com/scala/scala-lists.html https://www.jianshu.com/p/24c0ed2e3ae8 1. 默认scala的L ...
1
Spark MLlib基本算法相关性分析、卡方检验、总结器
日志一.相关性分析 1.简介 计算两个系列数据之间的相关性是统计中的常见操作.在spark.ml中提供了很多算法用来计算两两的相关性.目前支持的相关性算法是Pearson和Spearman.Correla ...
scala中执行shell命令
日志import sys.process._ //shell命令最后加上.!表示执行命令,也可是把执行结果赋值给一个不可变变量 //.!返回结果为int,0表示成功,.!!返回结果为打印的内容,为stri ...
1
intellij idea 打Scala jar包及执行
日志分两大块: 一.IDEA打可执行jar包 二.IDEA maven打可执行jar包 一.IDEA打可执行jar包 1.先创建IDEA的Scala project File-->New--> ...
5
scala 中下划线与星号 _*
日志1.变长参数 def sum(args:Int*): Unit ={ println("sum:",args.length,args.sum) } def main(args: A ...
Scala 可变map与不可变map互转
日志object test2 { def main(args: Array[String]): Unit = { val im = scala.collection.immutable.Map(1-> ...
11
IDEA+scala程序中调用日志-log4j
日志slf4j提供的是一个抽象的接口,实现可以是log4j.logback等,但是,运行时候只能有一个接口实现类. org.apache.hadoop:hadoop-common包自带log4j,mave ...
1
scala集合和Java集合对应转换操作
日志用Scala编码的时候,经常会遇到scala集合和Java集合互相转换的case, scala.collection.Iterable <=> java.lang.Iterable sca ...
2
scala中使用redis
日志redis命令参考网址:http://doc.redisfans.com/index.html 创建redis集群: import java.util.Properties import java.i ...