scala
0 人感兴趣 · 44 次引用
- 最新
- 推荐
浅谈 Kafka2.8+ 在 Windows 下的搭建与使用
周末空闲时间无意找到了一套个性化推荐的源码,整体项目运用了SSH,HDFS,Flume,Hive,Kafka,Spark,Scala等。运行时,本来通过spark计算业务埋点数据时,却发现本地没有Kafka。因为我一直也没使用过Kafka,所以也作为新人,浅谈以下Kafka的环境安装
聊聊 JavaScript 和 Scala 的表达式 Expression
我们先看下面这段简单的JavaScript代码。 我在第10行调用了函数f,其中传入的第二个和第三个参数都是一个逗号表达式。 函数f的实现,会检查这两个参数的类型,如果是函数,则执行函数调用,再打印其返回值,否则直接打印传入的表达式的值。
大数据培训 | Scala 语言知识分享,直击面试
类参数可以直接在类的主体中使用。类参数同样可以使用var作前缀,还可以使用private、protected、override修饰。scala编译器会收集类参数并创造出带同样的参数的类的主构造器。,并将类内部任何既不是字段也不是方法定义的代码编译至主构造器中_大数据培训
大数据培训 Scala 类和对象知识与案例分享
Scala中的类不声明为public,一个Scala源文件中可以有多个类。以上实例的类定义了两个变量 x 和 y ,一个方法:move,方法没有返回值_大数据培训。Scala 的类定义可以有参数,称为类参数,如上面的 xc, yc,类参数在整个类中都可以访问。
十分钟带汝入门大数据开发语言 Scala
Scala是一门多范式的编程语言,一种类似Java的编程语言 ,设计初衷是实现可伸缩的语言 、并集成面向对象编程和函数式编程的各种特性。目前最主流的大数据开发框架Spark的实现就是通过Scala去实现的。Scala可以与Java互操作。它用scalac这个编译器把源文件编
大数据开发之如何用 Scala 进行 spark 开发
1、开发第一个Spark程序 1)创建一个Spark Context 2)加载数据 3)把每一行分割成单词 4)转换成pairs并且计数
痛苦调优 10 小时,我把 Spark 脚本运行时间从 15 小时缩短到 12 分钟!
周一我就有个困惑,还写成文章了:如何从 Spark 的 DataFrame 中取出具体某一行,里面提了自己猜想的几种解决方案。
使用 Scala 宏解决对象转换
在 GrowingIO 服务端的开发中,我们使用 gRPC 进行微服务之间的数据通信,每个提供服务的项目,都要定义一套自己的 Protobuf 消息格式,然后利用 protoc 去生成对应语言的适配代码。
GitHub 霸屏文章!清华教授手写保姆级笔记 Scala - 类,网友:太香了
上一篇是分享的是《《MySQL主从复制》,这篇给大家分享《Scala - 类的定义》。
豆瓣 9.5 分,它是 Scala 领域当之无愧的王者之作!
今天博文菌要给大家带来一部蜚声世界的Scala编程圣经,它就是由Scala 语言缔造者Martin Odersky编写的——《Scala编程》。
Flink 在窗口上应用函数 -6-9
增量聚合函数:窗口内以状态形式存储某个值,且需要根据每个加入窗口的元素对该值进行更新。此类函数通常非常节省空间,且最终会将聚合值作为单个结果发送出去。如:ReduceFunction,AggregationFunction
Flink 时间服务和计时器 -6-5
系统对于processElement()和onTimer两个方法的调用是同步的,可以防止并发访问和操作状态。
Flink 处理函数 -6-4
DataStream API 提供了一组底层转换--处理函数,除了基本功能,还可以访问时间戳和水位线,并支持注册将来时间触发器,副输出功能可以将记录输出多个流
Flink 检查点存在的性能影响 -16
Flink的检查点在不停止整个应用的情况下为流式应用生成一致的分布式检查点,但是会增加延迟。Flink采取了一些策略