精简的Shell cat /home/sev7e0/access.log | tr -s ' ' '\n' | sort | uniq -c | sort -r | awk '{print $2, $1}' #cat 命…
分类:scala
Jakartase_多线程 --- 线程同步方法(一)--- 同步块(肆)
一、引言、大纲 在并发编程中发生的最常见的一种情况是超过一个执行线程使用共享资源。在并发 应用程序中,多个线程读或写相同的数据或访问同一文件或数据库连接这是正常 的。这些共享资源会引发错误或数据不一致的情况,我们必须通过…
Spark 2.3.1数据导入ElasticSearch 5.5.3
Spark 2.3.1数据导入ElasticSearch 5.5.3 TODO
使用maven方式创建spark项目(配置pom.xml文件)
创建maven项目后,在pom.xml文件中添加如下配置项: <properties> <maven.compiler.source>1.8</maven.compiler.source&g…
【Akka扩展】Akka Extensions
如果你想为 Akka 添加功能,那么有一个非常优雅且功能强大的机制。它被称为 Akka 扩展(Akka Extensions),由2个基本组件组成:Extension 和 ExtensionId。 每个 ActorSys…
大数据系列—— Scala的初步认识和语法入门
1. Scala简介 Scala是一门多范式(multi-paradigm)的编程语言,设计初衷是要集成面向对象编程和函数式编程的各种特性 Scala运行在Java虚拟机上,并兼容现有的Java程序 (Scala是类Jv…
spark本地环境的搭建到运行第一个spark程序
搭建spark本地环境 搭建Java环境 (1)到官网下载JDK下载地址:点击这里(2)解压缩到指定的目录 >sudo tar -zxvf jdk-8u91-linux-x64.tar.gz -C /usr/lib…
Jakartase 8_ — LambdaExpression (附)
一、前言 Lambda表达式是在Java8中引入的,并号称是Java8的最大的特点. Lambda表达式有利于函数式编程,简化了开发了很多。 允许把函数作为一个方法的参数(函数作为参数传递进方法中) λ表达式本质上是一个…
Akka actor tell, ask 函数的实现
tell (!) final def tell(msg: Any, sender: ActorRef): Unit = this.!(msg)(sender) tell 函数是 actor 的核心,actor 是事件 (…
Scala基于MySQL元数据管理项目实战
项目概述:Spring Boot + Spring Data JPA + Scala + Java (混编)(有些java工具类需要调用) 项目需求:统一元数据管理(metastore)在大数据平台的重要性(SparkS…
从源码层面理解Either、Option、Try
差异 Either 代表一个结果的两个可能性,一个是 Right ,一个是 Left Option 代表可选择的值,一个是 Some(代表有值),一个是 None (值为空);常用于结果可能为 null 的情况; Try…
强制Scala函数产生“副作用”
最近看到一个有意思的题目:波斯公主选驸马链接 ,手痒想写代码模拟实现一下。正好在做scala的项目,自然就想用scala来实现。 模型里首先要实现一个”洗牌算法” ,该算法用java实现的话如下:…