一、介绍 Flink分层组件栈 API支持 对Streaming数据类应用,提供DataStream API 对批处理类应用,提供DataSet API(支持Java/Scala) Libraries支持 支持机器学习(FlinkML) 支持图分析(Gelly) 支持关系数据处理(Table) 支持 ...
分类:
其他好文 时间:
2020-03-22 13:36:23
阅读次数:
79
上篇谈到:elasticsearch本身是一个完整的后台系统,对其的操作使用是通过终端api进行的。elasticsearch本身提供了多种编程语言的api,包括java的esjava。而elastic4s是一套基于esjava之上的scala api。 先看看scala 终端 ElasticCli ...
分类:
其他好文 时间:
2020-03-21 13:02:54
阅读次数:
72
Python 偏函数 简单的理解偏函数,它是对原始函数的二次封装,是将现有函数的部分参数预先绑定为指定值,从而得到一个新的函数,该函数就称为偏函数。相比原函数,偏函数具有较少的可变参数,从而降低了函数调用的难度。 定义偏函数,需使用 partial 关键字(位于 functools 模块中),其语法 ...
分类:
编程语言 时间:
2020-03-20 20:04:04
阅读次数:
63
python partial偏函数 from functools import partial def func(a,b,c,d): return a + b + c + d tes = partial(func,1) print(tes) res = tes(2,3,4) print(res) ...
分类:
编程语言 时间:
2020-03-20 17:00:33
阅读次数:
65
使用idea开发flink报错,就是普通的读取文本内容,进行单词计数。scala版本是2.11.12,flink是1.8.1报错信息如下:Exceptioninthread“main”java.lang.NoSuchMethodError:akka.actor.ActorSystemImpl.(Ljava/lang/String;Lcom/typesafe/config/Config;Ljava/
分类:
其他好文 时间:
2020-03-20 11:07:36
阅读次数:
189
1. scala 编程虽然类似于 python ,但也严格遵守Java的相关准则 .如导入类 , 依赖等 .并且可通用类库 . 其最好用的一点事对数据的类型转换更方便 结果是3600 , 转无数次也一样 ,虽然没必要 .但是在数据编程方面 , 会更方便. 这也是为什么Spark是用scala 开发. ...
分类:
其他好文 时间:
2020-03-20 09:13:28
阅读次数:
60
根本原因:double click 双击 移动端默认双击情况下会有方法效果,当你点击一次之后,移动端无法判断你是否下一次还会继续完成双击,因此存在300 ms 延迟 有一部分浏览器,比如chrome浏览器,当你在meta头设置width=device-width时,它会自动禁止300 ms的延迟 推 ...
分类:
移动开发 时间:
2020-03-17 14:18:49
阅读次数:
98
最近想用Scala来重构Java项目。Scala的灵活高效这里就不用说了,Java MVC一套架构确实有它优点。但是开发调试效率确实慢很多。所以准备使用DDD中的命令查询职责分离模式(Command Query Responsibility Segregation,CQRS)重构项目。 首先我们先介 ...
分类:
其他好文 时间:
2020-03-16 16:28:01
阅读次数:
101
scala 下载网站 https://www.scala-lang.org/download/ 安装scala要先安装java,并且配置java环境,官网也有说明 不过国内的网站下载不下来可以访问: http://downloads.typesafe.com/scala/2.13.0/scala-2 ...
分类:
其他好文 时间:
2020-03-15 19:16:15
阅读次数:
74