哇 这个方式很取巧了 好机智 我之前就是一直索引取值 学习一下
-- 原始邮件 --
发件人: Jark Wu
> Hi ,Dream
> >
> >
> > 比如你最终拿到的是Row(10),10表示有10个字段,这些字段的顺序是固定的,那么你可以把每个字段在row里的索引的映射关系保存下来,如下
> > map ,然后 row.getField(map.get(fieldName))获取你需要的值
> >
> >
> > 原始邮件
> > 发件人: Dream-底限
> > 收件人: user-zh
> > 发送时间: 2020年7月23日(周四) 14:
> 原始邮件
> 发件人: Dream-底限
> 收件人: user-zh
> 发送时间: 2020年7月23日(周四) 14:57
> 主题: Re: flink row 类型
>
>
> hi、xiao cai 可以说一下思路吗,我没太懂 》》可以考虑把字段索引值保存下来再获取 Dream-底限 <
> zhan...@akulaku.com> 于2020年7月23日周四 下午2:56写道: > hi、Jingsong Li >
> 我查看了对应的api,并运行了demo测试,通过CallContext
Hi ,Dream
比如你最终拿到的是Row(10),10表示有10个字段,这些字段的顺序是固定的,那么你可以把每个字段在row里的索引的映射关系保存下来,如下
map ,然后 row.getField(map.get(fieldName))获取你需要的值
原始邮件
发件人: Dream-底限
收件人: user-zh
发送时间: 2020年7月23日(周四) 14:57
主题: Re: flink row 类型
hi、xiao cai 可以说一下思路吗,我没太懂 》》可以考虑把字段索引值保存下来再获取 Dream-底限
于2020年7月23日周四 下午2:56写道
段索引值保存下来再获取
>>
>>
>> 原始邮件
>> 发件人: Dream-底限
>> 收件人: user-zh
>> 发送时间: 2020年7月23日(周四) 14:08
>> 主题: Re: flink row 类型
>>
>>
>> hi 是的,我们的数据场景比较尴尬,那我想其他方式实现一下 Benchao Li
>> 于2020年7月23日周四 下午12:55写道: > 这个应该是做不到的。name只是SQL plan过程的东西,在运行时它就
hi、Jingsong Li
我查看了对应的api,并运行了demo测试,通过CallContext我可以拿到对应的字段类型,但是无法拿到对应的字段名称
>>在TypeInference中有input的type,这个type应该是包含字段信息的。
xiao cai 于2020年7月23日周四 下午2:19写道:
> 可以考虑把字段索引值保存下来再获取
>
>
> 原始邮件
> 发件人: Dream-底限
> 收件人: user-zh
> 发送时间: 2020年7月23日(周四) 14:08
> 主题: Re: flink
可以考虑把字段索引值保存下来再获取
原始邮件
发件人: Dream-底限
收件人: user-zh
发送时间: 2020年7月23日(周四) 14:08
主题: Re: flink row 类型
hi 是的,我们的数据场景比较尴尬,那我想其他方式实现一下 Benchao Li 于2020年7月23日周四
下午12:55写道: > 这个应该是做不到的。name只是SQL plan过程的东西,在运行时它就没有什么实际意义了。 >
你是想在udf里面获取row里面每个字段的名字是吧?如果是的话,我理解现在应该是做不到的。 > > Dream-底限
于
可以看下Flink 1.11的UDF type inference.
在TypeInference中有input的type,这个type应该是包含字段信息的。
Best,
Jingsong
On Thu, Jul 23, 2020 at 2:09 PM Dream-底限 wrote:
> hi
> 是的,我们的数据场景比较尴尬,那我想其他方式实现一下
>
> Benchao Li 于2020年7月23日周四 下午12:55写道:
>
> > 这个应该是做不到的。name只是SQL plan过程的东西,在运行时它就没有什么实际意义了。
> > 你是想在udf里面获取row里面每个字
hi
是的,我们的数据场景比较尴尬,那我想其他方式实现一下
Benchao Li 于2020年7月23日周四 下午12:55写道:
> 这个应该是做不到的。name只是SQL plan过程的东西,在运行时它就没有什么实际意义了。
> 你是想在udf里面获取row里面每个字段的名字是吧?如果是的话,我理解现在应该是做不到的。
>
> Dream-底限 于2020年7月22日周三 下午7:22写道:
>
> > hi、
> > 我这面定义row数据,类型为ROW,可以通过
> > row.getField(i)获取到对应的值,但是我想获取对应的row_name名称要怎么操作,貌似没有报漏
这个应该是做不到的。name只是SQL plan过程的东西,在运行时它就没有什么实际意义了。
你是想在udf里面获取row里面每个字段的名字是吧?如果是的话,我理解现在应该是做不到的。
Dream-底限 于2020年7月22日周三 下午7:22写道:
> hi、
> 我这面定义row数据,类型为ROW,可以通过
> row.getField(i)获取到对应的值,但是我想获取对应的row_name名称要怎么操作,貌似没有报漏获取名称的接口
>
> rule_key 转换为rule_key1,rulekey2
> 1
> 2
>
--
Best,
Benchao Li
hi、
我这面定义row数据,类型为ROW,可以通过
row.getField(i)获取到对应的值,但是我想获取对应的row_name名称要怎么操作,貌似没有报漏获取名称的接口
rule_key 转换为rule_key1,rulekey2
1
2
11 matches
Mail list logo