Scala入门指南系列教程目录 Scala入门指南之配置环境 Scala入门指南之面向对象编程基础 Scala入门指南之面向对象编程进阶 Scala入门指南之集合(一) Scala入门指南之集合(二) Scala入门指南之函数式编程 Scala入门指南之Akka并发编程框架简介 前面介绍了那么多关于Scala的基础语法,终于迎来了了Scala入门指南的最后一篇——Akka简介。看标题读者就能知道,Akka是一个并发编程框架,也可以通俗点说,就是用来开发多线程的。Java中的多线程开发是使用加锁的机制来确保同一时间只…

2021年3月10日 0条评论 10点热度 阅读全文

Scala学习笔记——scala数据类型 文章目录 Scala学习笔记——scala数据类型 一、Hello World 二、数据类型与变量的定义 1、数据类型 2、变量的定义 三、打印数据到控制台 四、类型转换 1、隐式转换 2、强制类型转换 五、scala运算符 1、算数运算符 2、关系运算符 3、逻辑运算符 4、位运算符 一、Hello World 老规矩,学新语言先写hello world object HelloWorld { def main(args: Array[String]): Unit = {…

2021年3月4日 0条评论 46点热度 阅读全文

Akka Dispatcher是维持Akka Actor动作的核心组件,是整个Akka框架的引擎。它是基于Java的Executor框架来实现的。Dispatcher控制和协调消息并将其分发给运行在底层线程上的Actor,由它来负责调度资源的优化,并保证任务以最快的速度执行。 Akka的高稳定性是建立在“Let It Crash”模型之上的,该模型是基于Supervision和Monitoring实现的。通过定义Supervision和监管策略,实现系统异常处理。 Akka为了保证事务的一致,引入了STM的概念。S…

2021年1月16日 0条评论 26点热度 阅读全文

项目github地址:bitcarmanlee easy-algorithm-interview-and-practice 欢迎大家star,留言,一起学习进步 在函数式语言中,函数作为一等公民,可以在任何地方定义,在函数内或函数外,可以作为函数的参数和返回值,可以对函数进行组合。由于命令式编程语言也可以通过类似函数指针的方式来实现高阶函数,函数式的最主要的好处主要是不可变性带来的。没有可变的状态,函数就是引用透明(Referential transparency)的和没有副作用(No Side Effect)。 …

2021年1月15日 0条评论 29点热度 阅读全文

8种方法在java8中创建流对象(Stream)   0. 创建空的Stream empty()方法用来创建一个空的流 Stream<String> stream = Stream.empty(); stream.forEach(System.out::println);   这个方法经常被用在创建一个不含元素的空的流进行返回,避免返回null public Stream<String> streamOf(List<String> list) { return…

2021年1月14日 0条评论 28点热度 阅读全文

具体链接   https://github.com/jxnu-liguobin/SpringBoot-SecKill-Scala

2020年12月16日 0条评论 17点热度 阅读全文

俗称四不像应用。 预览 http://im.dreamylost.cn/ 代码 https://github.com/jxnu-liguobin/LayIM 采用Spring Boot、Scala、Akka HTTP 实现的LayIM。 非纯akka http。 由于不会写页面,暂时做不出来akkaHTTP替代springmvc的,网上唯一一个playframework支持thymeleaf的插件还是五年前的,不能用于新版本。 后续能做的可能是: 使用Playframework、play-ws重构整个项目 使用Ak…

2020年12月16日 0条评论 21点热度 阅读全文

我是scala和spark的新手,我有以下案例类Acase class A(uniqueId : String, attributes: HashMap[String, List[String]])现在我有了一个类型为A的dataFrame。我需要在该DF的每一行上调用一个Java函数。我需要将Hashmap转换为Java HashMap,并将List转换为Java list。我怎样才能做到这一点。 我正在尝试以下 val rddCaseClass = RDD[A] val a = rddCaseClass.toD…

2020年12月1日 0条评论 36点热度 阅读全文

我试图在scala sbt应用程序中使用纱线上的spark而不是直接使用​​。将纱线群集配置添加到Spark应用程序 我已经有一个远程纱线集群正在运行,并且我可以连接到SparkR中的纱线集群运行火花作业。但是当我尝试在scala应用程序中做类似的事情时,它无法将我的环境变量加载到纱线配置中,而是使用默认纱线地址和端口。 的SBT应用只是一个简单的对象: object simpleSparkApp { def main(args: Array[String]): Unit = { val conf = new Sp…

2020年11月28日 0条评论 29点热度 阅读全文

我试图将值插入Hive表中,并且如果每列都有值,则没有问题,但我需要在其中一列中插入NULL值。 我做这种事儿:将NULL值插入Hive with Spark中的dataFrame val errorsToAlert = List(("source1", "table1","27-01-2002", null)) val data = sqlContext.createDataFrame(errorsToAlert).toDF("source", "table_name", "open_date", "close_…

2020年11月27日 0条评论 32点热度 阅读全文