HI,
如题，想要在Flink
SQL中通过自定义UDF增加指标，从而实现自定义告警。那么如何在UDF中获取到RuntimeContext从而修改Metrics呢？
--
Sent from: http://apache-flink.147419.n8.nabble.com/
??
??Flink(1.8)SQL
??UDF,jsonname??name??value
(e.g.??appKey)
??json:
{"appKey": "qq", "eventId": "18", "name" :
[{"a":"jack","b":"mark","c":"tark"},{...},...]}
json??
{"a
/jira/browse/FLINK-15487
Best,
Jingsong Lee
On Tue, Jun 9, 2020 at 4:57 PM kcz <573693...@qq.com> wrote:
> 有道理呀，我直接map就好 。tks。
>
>
>
>
> -- 原始邮件 --
> 发件人: "1048262223"<1048262...@qq.com>;
> 发送时间: 2020年6月9日(星期二) 下午4:51
map ??tks??
-- --
??: "1048262223"<1048262...@qq.com>;
: 2020??6??9??(??) 4:51
??: "user-zh"
Hi
Map
Best,
Yichao Yang
-- --
??: "kcz"<573693...@qq.com>;
: 2020??6??9??(??) 4:49
??: "user-zh"
udfudf
-- --
??: "Benchao Li"
> > 如果有理解不对之处，敬请指出。
>> >
>> >
>> > Best,
>> > Yichao Yang
>> >
>> >
>> >
>> >
>> > -- 原始邮件 --
>> > 发件人: "forideal"> > 发送时间: 2020年6月9日(星期二) 中午1:33
>> >
m/yangyichao-mango/flink-protobuf
> 之后我会持续关注社区关于pb format的实现。
>
>
> Best,
> Yichao Yang
>
>
>
>
> -- 原始邮件 --
> 发件人: "Jark Wu" 发送时间: 2020年6月9日(星期二) 下午2:49
> 收件人: "user-zh"
> 主题: Re: Flink SQL UDF 动态类型
>
>
>
Hi
+1??avro??json??formatpb??flink-protobuf??formats??git
https://github.com/yangyichao-mango/flink-protobuf
pb format
Best,
Yichao Yang
-- --
??: "Jark W
>
> >
> >
> >
> > -- 原始邮件 --
> > 发件人: "forideal" > 发送时间: 2020年6月9日(星期二) 中午1:33
> > 收件人: "user-zh" >
> > 主题: Flink SQL UDF 动态类型
> >
> >
> >
> > 你好，我的朋友：
> >
> >
>
数类型应该定下来比较好一点。
>
>
> 如果有理解不对之处，敬请指出。
>
>
> Best,
> Yichao Yang
>
>
>
>
> -- 原始邮件 --
> 发件人: "forideal" 发送时间: 2020年6月9日(星期二) 中午1:33
> 收件人: "user-zh"
> 主题: Flink SQL UDF 动态类型
>
>
>
> 你好，我的朋友：
&g
Hi
pbpb??schema(descriptor)??TypeInformationenv.addSource().returns()??TypeInformation??TypeInformation??
??udfudf?
你好，我的朋友：
我使用的是 Flink 1.10 Blink Planer。
我想构造一个Flink UDF ，这个 UDF 可以根据不同的参数返回不同的类型。
为什么我想要这个功能：
场景1: 我的数据是一个 pb 的 bytes，我想从里面获取数据，如果统一的返回 string，后面还需要 cast 比较繁琐，如果使用
get_int、get_double、get_string 这样的方式，实现起来又非常多
场景2: 我的数据是一个 Json ，问题同上。
在场景1中，我改了下 Flink 的源码，在
13 matches
Mail list logo
