00:00
好,那接下来呢,在弗Li当中,它还有一个工具啊叫perter to啊这个工具,这个之前大家在最早的时候写的那个Li程序里边已经接触过了啊,这个parater处啊,但是呢,可能现在已经忘了,就是说呢,他是干什么事呢,可以因为如果说啊,比方说。呃,这个地方对吧,我写一个代码啊,在这边写一个测试代码。APP对吧,嗯,然后呢,我稍微的去写一写啊,因为等会呢,刚好也要用flink这个test优化了一个test啊,那就叫这个名字吧。好,那在这里边呢,PSM,然后呢,比方说要第一步获取这个我就不写了,这个地方我就不写那个注释了,STEM execution environment。Get get得到一个烟对吧。
01:01
在的平度,假如说是二吧,这个无所谓了啊,二三都行啊呃,那接下来呢,我们比方说我们从一个端口取读数据,那就是socket,对吧,Text stream,然后呢,给一个主机名,给一个端口号。这边是。有问题吗?胡金明端口号延迟,诶好这个地方。因为点。他现在要这个分割符和最大的重试了是吗?我现在倒的是12呀,又改了。好,那比方说吧,我们就来这个啊,首先一个这个呃,然后还有一个分割符,比方说有一个逗号对吧,分割的,然后接下来是最大的重试次数,假如说两侧吧。
02:05
这个地方要一个叉对吧,看呃,这还比较麻烦啊,这个地方它现在这个我是导错了吗?这个东西。倒错包了是吗?啊对对对,这这个地方API对对这个这个包错了,该是这个。应该是这个什么,不是skyla的么?说呢,这不奇怪,对吧,这就对了对吧,不用这个不用这个,这差还搞一个叉数据,这就是正常的一个移民一个。正号。一个主机名一个账号对吧,好,那呃,诶那个东西呢,给我关掉了是吧,这个啊。一个主机名,一个正号,那这个东西讲的是什么事呢?比方说我现在不想这样写死,我想从外面传进来也可以吧,我就用的是什么X0,这个呢,用inrIgEr填past in,然后呢,X1也可以啊,那我们未来在启动任务的时候,我是不是可以第一个参数写一个主机名,第二个参数给一个段号二,那这样呢可以传进来。
03:26
对吧,可以传进来,但是它有个缺点就在于你必须要保证顺序。第一个是主题名,你把它写反了,写反了不行对吧?好,那这个里边permit true。To这个工具呢,就有一个很好用的一个点在于这啊,这是flink所提供的,比方说这边等下这个包点FXX内容呢做一个解析啊,那怎么解析呢,点我们可以get string啊,比方说。我们看一下啊,点get。
04:01
诶,String对吧,呃,那这个地方呢,是我们的host看得到一个house,然后呢,At in对吧,然后port,而加到一个port,那下来呢,这个地方就不用它了,而用的是host,用的是port。对吧?啊,那这两者有什么区别呢?刚才我们看到的X1,那我们把这个再写上啊。这个地方呢叫A0,然后呢,这个地方是in t.us in,然后呢A对吧?好这种呢写的是house board,这个就是严格遵守顺序就好了,就是你的顺序不能错。直接放对吧,直接放就好了,而这种我们通过这个para to这个工具解析的内容呢,那它参数是这样传的放杠号注意啊。
05:04
是吧,杠杠host哈杜102,那这边你传的就是哈102,然后呢,9999对吧,而这边是杠杠host,然后杠杠或啊这俩的顺序呢,就可以随便换。可以随便换啊,就是这个意思对吧,它是通过KV来传进来的啊,KV因为只要你通过KV的方式来传进来参数的话,那么它就可以随便换位置啊,如果说用的是X0X1这种方式,那不好意思诶,不能换位置,不能换位置对吧?它可以做这个内容啊,就是说通过它来加载这个信息,你可以在这里面指定对吧,比方说。Use nameme job name对吧,在这边指定job name,然后呢,杠杠job name传进来。然后缠起来就好了,然后在这里面呢,可以通过这种方式来获取,对吧,就刚才我们写的那个啊,然后呢,这个地方也可以读取这个系统的属性啊,系统属性直接permit to.from system啊这个地方我们看一下啊,点from。
06:11
还有system啊,它有这个系统的配置信息啊,你可以把它打印一下当前,呃,我们在Windows里面运行对吧,Windows执行的路径Java后,然后呢,用户名这些东西呢,都能打印出来获取系统的配置信息,对吧?这是也是一个点啊,第二个第三个可以用来读取这个配置文件。啊,以前我们是不是写那个叫啊。对吧,用po u来读取这个配置信息,但实际上在flink当中,我们可以用这个参数工具来读取配置信息啊,然后读取之后呢,它还是KV类型的。还是这个KV类型的啊,然后注册这个全局参数什么意思呢,相当于在。里边那种广播变量的方式那种感觉啊,那这边呢,我们可以怎么做,在这个地方看一看啊。
07:03
因为然后呢,Inv.get con。把我们传进来的参数作为全局的参数设置到环境当中,对吧,然后接下来在这边可以运行是上下文,然后呢,获取直音。信息,获取全局的配置信息,也就是说在我们的manager当中去注册这个内容,然后到task manager里面去用。啊去用你可以直接去拿到对吧?啊是这个意思,它也可以获取到这个内容啊,这个其实就是一个工具啊,就是一个工具对吧,叫排处啊这个知道一下啊,它呢很方便可以做这些事情,第一个运行参数,也就是说你通过慢方法给慢方法传达参数,以前直接按看位置,现在呢,我可以变成。KV形式对吧,那第二个读取系统的属性,一般的也很少读这个读取配置文件,这个可能会用的,对吧?啊,因为我们自己搞这个配置文件,配置了一些端口啊,或者主机名啊,我们可以把这个读取过来啊,另外读取全局参数啊,注册全局参数,其实这个也比较少用啊,用的比较少行,这是排名的处啊,这是一个工具。
我来说两句