温馨提示:文本由机器自动转译,部分词句存在误差,以视频为准
00:00
那接下来我们介绍一下一些使用的一些细节吧,啊,那第一个呢是类型映射。那类型映射就是flink里面的字段类型跟who体当中的字段类型是一个什么关系?有哪一些限制啊?那举个简单例子啊,你看如果flink circle中咱们定义为char ver string,那么其实在who底当中体现为什么?就是一个string?那这个玩意儿,那我们对于我们有什么影响呢。影响很简单,就是如果我们写代码,不管你在哪写啊,不管你是客户端还是idea去编程,编呃编码,那么你去是不是要create table。对吧,你可以去create table,那这个时候你能不能定义为verar呢?可以没问题,它是支持的,对吧,那对应的户体里面会体现为是最类型无所谓,就是说左边这一列就是咱们可以写的类型,能理解我意思不对吧,好。
01:05
呃,或者你直接用who底对应的类型明确去去写也可以啊,我举个例子啊,像我之前写过的一些项目当中的,呃,举个例子啊,那你看我这个是什么who体表,那我这个who体表是不是可以定义为big int char,呃,Times temp是不是都OK啊,也可以定义为什么string,这都允许的啊,因为这边的类型咱们主要关注的是flink的类型啊。而且我们只要知道这个类型护底能对应上那就OK了啊,所以我们就关注左边这一列,就是我们可以写的啊,或者你直接写护底的类型也是OK的,更规范一点啊。那我们就找找特殊的啊,比如说binary。这些它是BI啊,支持disim,支持tiny int,什么跟int相关的都支持,你写long也可以,好吧,你写long也可以,还有double啊,都OK。
02:01
这个date啊,关于日期咱们就要注意的,你看关于这个date啊,它是用int来表示啊,Int来表示time它也有啊,Time STEM,也就是说flink当中是不是有分为day time time STEM,对吧,那你就正常去在flink正常去写这个类型就行了啊,反正回头他能识别了啊。好了,呃,那还有一个A啊,支持也就复杂类型的话,咱们第一个数组都支持,第二个map都支持,但是我想提醒你的是,这个时候你用flink定义为map类型,OK,但是你的key的类型必须是字符串类型啊,也就是这些。要不然他就报错了,因为什么呢?因为回头他这些是不是要,呃,比如说咱们用二表的是不是要做一个阿芙罗序列化。对吧?啊,那如果你不是string的话,它会报错的啊,那同样的multi set。Flink当中mon set,它也支持那。在这个库里面,它是用map来对应啊。
03:02
那还有一种咱们have是不是有一个东西叫这种类型啊。Have当中啊,对不对,那平时我们flink对接have的时候,Struck类型是不是都可以用肉这种格式来表示对吧?啊,那么whodi也是支持呃,有对应的类型,跟他对应是什么呢?Record类型表数据类型啊,都一个意思啊,这几个单独提的是我们要注意的事,也就一般情况下大部分类型都OK啊,有几个东西要注意,必须是最啊,这个multi set元素必须也是什么字符串类型啊。好,那这玩意儿就是一个类型的映射,就你正常写要出现问题,你再来查这张查这个就可以了,好吧。嗯。
我来说两句