scala

akka-streams - 从应用角度学习:basic stream parts
日志   实际上很早就写了一系列关于akka-streams的博客.但那个时候纯粹是为了了解akka而去学习的,主要是从了解akka-streams的原理为出发点.因为akka-streams是akka系 ...
akka-grpc - 应用案例
日志  上期说道:http/2还属于一种不算普及的技术协议,可能目前只适合用于内部系统集成,现在开始大面积介入可能为时尚早.不过有些项目需求不等人,需要使用这项技术,所以研究了一下akka-grpc,写了 ...
akka-grpc - 基于akka-http和akka-streams的scala gRPC开发工具
日志 关于grpc,在前面的scalaPB讨论里已经做了详细的介绍:google gRPC是一种全新的RPC框架,在开源前一直是google内部使用的集成工具.gRPC支持通过http/2实现protob ...
akka-typed(10) - event-sourcing, CQRS实战
日志在前面的的讨论里已经介绍了CQRS读写分离模式的一些原理和在akka-typed应用中的实现方式.通过一段时间akka-typed的具体使用对一些经典akka应用的迁移升级,感觉最深的是EvenSou ...
akka-typed(9) - 业务分片、整合,谈谈lagom, 需要吗?
日志  在讨论lagom之前,先从遇到的需求开始介绍:现代企业的it系统变得越来越多元化.复杂化了.线上.线下各种系统必须用某种方式集成在一起.从各种it系统的基本共性分析:最明显的特征应该是后台数据库的 ...
akka-typed(8) - CQRS读写分离模式
日志 前面介绍了事件源(EventSource)和集群(cluster),现在到了讨论CQRS的时候了.CQRS即读写分离模式,由独立的写方程序和读方程序组成,具体原理在以前的博客里介绍过了.akka-t ...
1
akka-typed(7) - cluster:sharding, 集群分片
日志  在使用akka-typed的过程中发现有很多地方都简化了不少,变得更方便了,包括:Supervision,只要用Behaviors.supervise()把Behavior包住,很容易就可以实现这 ...
1
scala 循环中continue和break
日志1. continue import scala.util.control.Breaks._ for(){ breakable{ if(){ break // continue } } } 2.bre ...
1
scala集合-collection
日志参考:https://www.jianshu.com/p/69bff3c7ec97 Scala的集合类可以从三个维度进行切分: 可变与不可变集合(Immutable and mutable colle ...
scala集合-List
日志参考:https://www.runoob.com/scala/scala-lists.html https://www.jianshu.com/p/24c0ed2e3ae8 1. 默认scala的L ...
入门大数据---Scala学习
日志Scala是什么? Scala是一种基于函数式编程和面向对象的高级语言.它开发了Spark等大型应用.它和Java有效集成,底层也是支持JVM的. 它有六大特性: 无缝JAVA互操作 Scala在JV ...
Spark MLlib基本算法相关性分析、卡方检验、总结器
日志一.相关性分析 1.简介 计算两个系列数据之间的相关性是统计中的常见操作.在spark.ml中提供了很多算法用来计算两两的相关性.目前支持的相关性算法是Pearson和Spearman.Correla ...
scala中执行shell命令
日志import sys.process._ //shell命令最后加上.!表示执行命令,也可是把执行结果赋值给一个不可变变量 //.!返回结果为int,0表示成功,.!!返回结果为打印的内容,为stri ...
intellij idea 打Scala jar包及执行
日志分两大块: 一.IDEA打可执行jar包 二.IDEA maven打可执行jar包 一.IDEA打可执行jar包 1.先创建IDEA的Scala project File-->New--> ...
4
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 ...
scala集合和Java集合对应转换操作
日志用Scala编码的时候,经常会遇到scala集合和Java集合互相转换的case, scala.collection.Iterable <=> java.lang.Iterable sca ...
1
scala中使用redis
日志redis命令参考网址:http://doc.redisfans.com/index.html 创建redis集群: import java.util.Properties import java.i ...
Scala学习笔记之Actor多线程与线程通信的简单例子
日志题目:通过子线程读取每个文件,并统计单词数,将单词数返回给主线程相加得出总单词数 package review import scala.actors.{Actor, Future} import s ...