补充阅读

补充阅读

02. 字符串转Interger

Integer.valueOf('123 ')将字符串转换为整数类型。

Integer.parseInt('123 ')将字符串转换为带符号的Int类型。

03. 富函数（Rich Functions）

富函数是DataStream API提供的一个函数类的接口，所有的Flink函数类都有自己丰富的版本。与常规功能不同，它可以获取运行环境的上下文，并且有一些生命周期方法，因此可以实现更复杂的功能。

RichMapFunction

RichFlatMapFunction

RichFilterFunction

丰富功能有一个生命周期的概念。典型的生命周期方法有：

Open()方法是富函数的初始化方法。open()将在调用map或filter等运算符之前调用。

close()方法是生命周期中最后一个被调用的方法，执行一些清理工作。

getRuntimeContext()方法提供了一些关于函数RuntimeContext的信息，例如函数执行的并行度、任务的名称和状态状态。

富函数普遍拥有方法：

打开(配置):无效

close():void

setRuntimeContext(RuntimeContext): void

getRuntimeContext(): runtimecontext

私有变量：运行时上下文3360运行时上下文

04. 正则字符串切割("\W+" 与"\s+"的区别)

\W:可以，匹配除字母、数字、下划线和汉字以外的任何字符。

\s :是匹配的空格，制表符(点击键)

05. 生成随机序列号（UUID）

类别：

UUID.randomUUID()。toString()。子字符串(0，18)

06. 生成随机数 Random的使用

生成整数[0，2]

random r=new Randow()；

r . Nextint(3)；//[0，3]，即0，1，2

07. 系统当前毫秒值

System.currentTimeMillis()

08. 线程休眠

时间单位。millises . sleep(50)；//线程休眠50毫秒

时间单位。seconds . sleep(1)；//线程休眠1秒

09. 序列化和反序列化

序列化是将一个对象序列化为二进制数据，保存在本地或通过网络传输到其他节点。

反序列化是将二进制数据反序列化为对象。

序列化和反序列化可用于在网络中传输对象。

对象的本质实际上是内存中某个存储区域的数据。

10. scala与Java元组元素的个数

Scala元组最多有22个元素。

java元组元素的最大数量是25。

11. Java中获取元祖元素

方法1:getField(0)

模式2 :f0。

12. Java中时间戳转指定日期格式

首先定义转换格式。

快速日期格式=快速日期格式. getinstance(' yyyy-MM-DD hh :MM 3360s 3360 ss ')

变化

system . out . println(format . format(123))

结果：

13. Spark 和 Flink 代码书写套路

火花

1、

2、

3、

4、

5、

弗林克

1.执行环境-环境

2.数据源-源

3.数据转换-转换

4.输出终端接收器

5.触发执行-执行

(添加带水槽的批处理，不添加任何人)

(必须将execute添加到流处理中才能触发executor)

14. 切割字符串时的细节点

密码

结果：

第：号结论

如果前面的一个被剪切，那么获得的第一个字符串数组必须有一个空字符串。

注意结局也是剪的，但结局不是。

15. TimeZone 时区中没有Asia/Beijing, 只有Asia/Shanghai 和 Asia/Chongqing

16. 字符串格式化format （本质：字符串填空）

Random Random=new Random()；

时区=时区. getTimeZone('亚洲/重庆')；

instant instant=instant . ofepochmilli(

system . CurrentiMellis(). Tizone . getoffset(system . CurrentiMellis())

);

system . out . println(instant . ToString())；

字符串输出=字符串。格式(

{ \ ' ts \ ' : \ ' % s \ '，\ ' user _ id \ ' : \ ' % s \ '，\ ' item _ id \ ' : \ ' % s \ '，\ ' category _ id \ ' : \ ' % s \ ' } '，

instant.toString()，

user _ '(10000 random . nextint(10000))，

item _ '(100000 random . nextint(100000))，

category _ '(200 random . nextint(200))

);

system . out . println(ou tut)；

17. fastjson的使用

import.com . Alibaba . fastjson . JSON；

功能：

JavaBean="]JSON格式字符串

JSON格式字符串=“JavaBean”

用法：

JSON . TojsonString(JavaBean)；//将JavaBean对象转换为JSON格式字符串

@数据

@NoArgsConstructor

@AllArgsConstructor

私有静态类DataBean {

私有字符串值；

}

DataBean数据=新的DataBean(string . value of(I))；

JSON.toJSONString(数据)；