写点什么

scala

0 人感兴趣 · 44 次引用

  • 最新
  • 推荐

浅谈 Kafka2.8+ 在 Windows 下的搭建与使用

用户头像
北桥苏
18 小时前

​ 周末空闲时间无意找到了一套个性化推荐的源码,整体项目运用了SSH,HDFS,Flume,Hive,Kafka,Spark,Scala等。运行时,本来通过spark计算业务埋点数据时,却发现本地没有Kafka。因为我一直也没使用过Kafka,所以也作为新人,浅谈以下Kafka的环境安装

https://static001.geekbang.org/infoq/a4/a451523fe958aa69ab1336827c57817d.jpeg?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

聊聊 JavaScript 和 Scala 的表达式 Expression

我们先看下面这段简单的JavaScript代码。 我在第10行调用了函数f,其中传入的第二个和第三个参数都是一个逗号表达式。 函数f的实现,会检查这两个参数的类型,如果是函数,则执行函数调用,再打印其返回值,否则直接打印传入的表达式的值。

Scala 基础 (六):面向对象(下篇)

在之前的文章中总结了Scala面向对象模块基础的内容,接下来学习面向对象的高阶内容。

Scala 基础 (五):面向对象(上篇)

Scala 的面向对象思想和 Java 的面向对象思想和概念是一致的,但是对应的语法有所不同。

大数据培训 | Scala 语言知识分享,直击面试

用户头像
@零度
2022-07-01

​类参数可以直接在类的主体中使用。类参数同样可以使用var作前缀,还可以使用private、protected、override修饰。scala编译器会收集类参数并创造出带同样的参数的类的主构造器。,并将类内部任何既不是字段也不是方法定义的代码编译至主构造器中_大数据培训

Scala 基础 (四):函数式编程【从基础到高阶应用】

学习函数时编程之前我们先来了解一下目前比较流行的、不同的编程范式。

Scala 基础 (三):运算符和流程控制

Scala中的运算符和Java中的运算符基本相同。

大数据培训 Scala 类和对象知识与案例分享

用户头像
@零度
2022-06-27

​Scala中的类不声明为public,一个Scala源文件中可以有多个类。以上实例的类定义了两个变量 x 和 y ,一个方法:move,方法没有返回值_大数据培训。Scala 的类定义可以有参数,称为类参数,如上面的 xc, yc,类参数在整个类中都可以访问。

https://static001.geekbang.org/infoq/52/529140c6f40592125900e2056ceed0fd.png?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

十分钟带汝入门大数据开发语言 Scala

Scala是一门多范式的编程语言,一种类似Java的编程语言 ,设计初衷是实现可伸缩的语言 、并集成面向对象编程和函数式编程的各种特性。目前最主流的大数据开发框架Spark的实现就是通过Scala去实现的。Scala可以与Java互操作。它用scalac这个编译器把源文件编

大数据开发之如何用 Scala 进行 spark 开发

用户头像
@零度
2021-11-26

​1、开发第一个Spark程序 1)创建一个Spark Context 2)加载数据 3)把每一行分割成单词 4)转换成pairs并且计数

https://static001.geekbang.org/infoq/73/73ef09f7d0706cbf891eab27c509c93c.png?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

痛苦调优 10 小时,我把 Spark 脚本运行时间从 15 小时缩短到 12 分钟!

用户头像
小拍Piper
2021-07-22

周一我就有个困惑,还写成文章了:如何从 Spark 的 DataFrame 中取出具体某一行,里面提了自己猜想的几种解决方案。

https://static001.geekbang.org/infoq/05/05faee791f07a6a281117a66d3065391.png?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

使用 Scala 宏解决对象转换

在 GrowingIO 服务端的开发中,我们使用 gRPC 进行微服务之间的数据通信,每个提供服务的项目,都要定义一套自己的 Protobuf 消息格式,然后利用 protoc 去生成对应语言的适配代码。

https://static001.geekbang.org/infoq/4a/4a2bcc8d640725d62ac2e74cf8e467ef.jpeg?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

GitHub 霸屏文章!清华教授手写保姆级笔记 Scala - 类,网友:太香了

上一篇是分享的是《《MySQL主从复制》,这篇给大家分享《Scala - 类的定义》。

https://static001.geekbang.org/infoq/2b/2beb22035152db900ae3c14058358cfc.png?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

豆瓣 9.5 分,它是 Scala 领域当之无愧的王者之作!

今天博文菌要给大家带来一部蜚声世界的Scala编程圣经,它就是由Scala 语言缔造者Martin Odersky编写的——《Scala编程》。

Scala 中 String 和 Int 隐式转换的问题分析

用户头像
木子李G
2020-12-11

分析Scala中String和Int的相关源码,发现隐式转换过程中的问题根源,给出解决方案。

https://static001.geekbang.org/infoq/44/44813dee71d074cfe9e3ad9b3db84f23.jpeg?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

Scala- 语法特性 (一):类型和变量定义

用户头像
正向成长
2020-11-13

Scala的变量类型和变量的定义方法

Flink 在窗口上应用函数 -6-9

用户头像
小知识点
2020-10-28

增量聚合函数:窗口内以状态形式存储某个值,且需要根据每个加入窗口的元素对该值进行更新。此类函数通常非常节省空间,且最终会将聚合值作为单个结果发送出去。如:ReduceFunction,AggregationFunction

Flink 窗口算子 -6-8

用户头像
小知识点
2020-10-22

窗口算子提供了一种基于有限大小的桶对事件进行分组,并对这些桶中有限大小的数据进行计算

Flink 向副输出发送数据 6-6

用户头像
小知识点
2020-10-18

大多数DataStream API的算子都只有一个输出,即只能生成某个数据类型的结果流

Flink 时间服务和计时器 -6-5

用户头像
小知识点
2020-10-17

系统对于processElement()和onTimer两个方法的调用是同步的,可以防止并发访问和操作状态。

Flink 处理函数 -6-4

用户头像
小知识点
2020-10-16

DataStream API 提供了一组底层转换--处理函数,除了基本功能,还可以访问时间戳和水位线,并支持注册将来时间触发器,副输出功能可以将记录输出多个流

Flink 周期性水位线分配器 -6-3

用户头像
小知识点
2020-10-15

指示系统以固定的机器时间间隔来发出水位线,并推动事件时间前进。

分配时间戳和生成水位线

用户头像
小知识点
2020-10-14

每个事件都需要关联一个时间戳,该时间戳表示事件真实发生的时间

Flink 从保存点启动应用 -18

用户头像
小知识点
2020-09-06

保存点保存和从保存点启动应用

Flink 保存点 -17

用户头像
小知识点
2020-09-05

Flink的故障恢复算法是基于状态的检查点来完成的,保存点作用

Flink 检查点存在的性能影响 -16

用户头像
小知识点
2020-09-04

Flink的检查点在不停止整个应用的情况下为流式应用生成一致的分布式检查点,但是会增加延迟。Flink采取了一些策略

scala_scala技术文章_InfoQ写作社区