You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by "wangweiguang@stevegame.cn" <wa...@stevegame.cn> on 2020/06/19 07:31:53 UTC

回复: 关于拓展 Tuple元组的问题

   多个值组合在一起,当一个复合值使用!



 
发件人: 魏旭斌
发送时间: 2020-06-19 15:01
收件人: user-zh
主题: 关于拓展 Tuple元组的问题
目前Flink 提供了Tuple1 ~ Tuple25,在实际开发中不能满足我们的需求,我们希望能有更大的元组,比如构建一个Tuple50。 请问有什么解决的方案? 谢谢 

Re:Re: 回复: 关于拓展 Tuple元组的问题

Posted by Weixubin <18...@163.com>.
感谢,这边做了一下简单测试,已解决~   真香




//Demo
import org.apache.flink.api.common.typeinfo.TypeInformation;
import org.apache.flink.api.common.typeinfo.Types;
import org.apache.flink.table.functions.TableFunction;
import org.apache.flink.types.Row;


public class ParseUriRow extends TableFunction<Row> {
    
    public void eval(String data) {
        //逻辑处理
    }
    
    @Override
    public TypeInformation<Row> getResultType() {
        return Types.ROW(
                Types.STRING,
                Types.STRING,
                Types.STRING,
                Types.STRING,
                Types.STRING,
                Types.STRING,
                Types.STRING,
                Types.STRING,
                Types.STRING,
                Types.STRING,
                Types.STRING,
                Types.STRING,
                Types.STRING,
                Types.STRING,
                Types.STRING,
                Types.STRING,
                Types.STRING,
                Types.STRING,
                Types.STRING,
                Types.STRING,
                Types.STRING,
                Types.STRING,
                Types.STRING,
                Types.STRING,
                Types.STRING,
                Types.STRING
        );
    }
}
 


















在 2020-06-19 15:46:42,"Jark Wu" <im...@gmail.com> 写道:
>用 Row 啊,支持 Int.MAX 个元素,还能支持 null 值,不香么?
>
>
>On Fri, 19 Jun 2020 at 15:42, Weixubin <18...@163.com> wrote:
>
>> 感谢你的回答,请问可否举一个参照例子?
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>> 在 2020-06-19 15:31:53,"wangweiguang@stevegame.cn" <
>> wangweiguang@stevegame.cn> 写道:
>> >
>> >   多个值组合在一起,当一个复合值使用!
>> >
>> >
>> >
>> >
>> >发件人: 魏旭斌
>> >发送时间: 2020-06-19 15:01
>> >收件人: user-zh
>> >主题: 关于拓展 Tuple元组的问题
>> >目前Flink 提供了Tuple1 ~ Tuple25,在实际开发中不能满足我们的需求,我们希望能有更大的元组,比如构建一个Tuple50。
>> 请问有什么解决的方案? 谢谢
>>

Re: 回复: 关于拓展 Tuple元组的问题

Posted by LakeShen <sh...@gmail.com>.
哈哈,学习了一波

Jingsong Li <ji...@gmail.com> 于2020年6月30日周二 上午9:59写道:

> > 用Row 和 Tuple 性能上会有差别吗?
>
> 理论上有细微的差别,
> 但是,基本上性能瓶颈不会在这里。。所以你应该感受不到
>
> Best,
> Jingsong
>
> On Tue, Jun 30, 2020 at 8:51 AM zhisheng <zh...@gmail.com> wrote:
>
> > 可以测试一下
> >
> > Tianwang Li <li...@gmail.com> 于2020年6月29日周一 下午8:13写道:
> >
> > > >
> > > > 用 Row 啊,支持 Int.MAX 个元素,还能支持 null 值,不香么?
> > > >
> > > 用Row 和 Tuple 性能上会有差别吗?
> > >
> > > Jark Wu <im...@gmail.com> 于2020年6月19日周五 下午3:47写道:
> > >
> > > > 用 Row 啊,支持 Int.MAX 个元素,还能支持 null 值,不香么?
> > > >
> > > >
> > > > On Fri, 19 Jun 2020 at 15:42, Weixubin <18...@163.com> wrote:
> > > >
> > > > > 感谢你的回答,请问可否举一个参照例子?
> > > > >
> > > > >
> > > > >
> > > > >
> > > > >
> > > > >
> > > > >
> > > > >
> > > > >
> > > > >
> > > > >
> > > > >
> > > > >
> > > > >
> > > > >
> > > > >
> > > > >
> > > > > 在 2020-06-19 15:31:53,"wangweiguang@stevegame.cn" <
> > > > > wangweiguang@stevegame.cn> 写道:
> > > > > >
> > > > > >   多个值组合在一起,当一个复合值使用!
> > > > > >
> > > > > >
> > > > > >
> > > > > >
> > > > > >发件人: 魏旭斌
> > > > > >发送时间: 2020-06-19 15:01
> > > > > >收件人: user-zh
> > > > > >主题: 关于拓展 Tuple元组的问题
> > > > > >目前Flink 提供了Tuple1 ~
> > Tuple25,在实际开发中不能满足我们的需求,我们希望能有更大的元组,比如构建一个Tuple50。
> > > > > 请问有什么解决的方案? 谢谢
> > > > >
> > > >
> > >
> > >
> > > --
> > > **************************************
> > >  tivanli
> > > **************************************
> > >
> >
>
>
> --
> Best, Jingsong Lee
>

Re: 回复: 关于拓展 Tuple元组的问题

Posted by Jingsong Li <ji...@gmail.com>.
> 用Row 和 Tuple 性能上会有差别吗?

理论上有细微的差别,
但是,基本上性能瓶颈不会在这里。。所以你应该感受不到

Best,
Jingsong

On Tue, Jun 30, 2020 at 8:51 AM zhisheng <zh...@gmail.com> wrote:

> 可以测试一下
>
> Tianwang Li <li...@gmail.com> 于2020年6月29日周一 下午8:13写道:
>
> > >
> > > 用 Row 啊,支持 Int.MAX 个元素,还能支持 null 值,不香么?
> > >
> > 用Row 和 Tuple 性能上会有差别吗?
> >
> > Jark Wu <im...@gmail.com> 于2020年6月19日周五 下午3:47写道:
> >
> > > 用 Row 啊,支持 Int.MAX 个元素,还能支持 null 值,不香么?
> > >
> > >
> > > On Fri, 19 Jun 2020 at 15:42, Weixubin <18...@163.com> wrote:
> > >
> > > > 感谢你的回答,请问可否举一个参照例子?
> > > >
> > > >
> > > >
> > > >
> > > >
> > > >
> > > >
> > > >
> > > >
> > > >
> > > >
> > > >
> > > >
> > > >
> > > >
> > > >
> > > >
> > > > 在 2020-06-19 15:31:53,"wangweiguang@stevegame.cn" <
> > > > wangweiguang@stevegame.cn> 写道:
> > > > >
> > > > >   多个值组合在一起,当一个复合值使用!
> > > > >
> > > > >
> > > > >
> > > > >
> > > > >发件人: 魏旭斌
> > > > >发送时间: 2020-06-19 15:01
> > > > >收件人: user-zh
> > > > >主题: 关于拓展 Tuple元组的问题
> > > > >目前Flink 提供了Tuple1 ~
> Tuple25,在实际开发中不能满足我们的需求,我们希望能有更大的元组,比如构建一个Tuple50。
> > > > 请问有什么解决的方案? 谢谢
> > > >
> > >
> >
> >
> > --
> > **************************************
> >  tivanli
> > **************************************
> >
>


-- 
Best, Jingsong Lee

Re: 回复: 关于拓展 Tuple元组的问题

Posted by zhisheng <zh...@gmail.com>.
可以测试一下

Tianwang Li <li...@gmail.com> 于2020年6月29日周一 下午8:13写道:

> >
> > 用 Row 啊,支持 Int.MAX 个元素,还能支持 null 值,不香么?
> >
> 用Row 和 Tuple 性能上会有差别吗?
>
> Jark Wu <im...@gmail.com> 于2020年6月19日周五 下午3:47写道:
>
> > 用 Row 啊,支持 Int.MAX 个元素,还能支持 null 值,不香么?
> >
> >
> > On Fri, 19 Jun 2020 at 15:42, Weixubin <18...@163.com> wrote:
> >
> > > 感谢你的回答,请问可否举一个参照例子?
> > >
> > >
> > >
> > >
> > >
> > >
> > >
> > >
> > >
> > >
> > >
> > >
> > >
> > >
> > >
> > >
> > >
> > > 在 2020-06-19 15:31:53,"wangweiguang@stevegame.cn" <
> > > wangweiguang@stevegame.cn> 写道:
> > > >
> > > >   多个值组合在一起,当一个复合值使用!
> > > >
> > > >
> > > >
> > > >
> > > >发件人: 魏旭斌
> > > >发送时间: 2020-06-19 15:01
> > > >收件人: user-zh
> > > >主题: 关于拓展 Tuple元组的问题
> > > >目前Flink 提供了Tuple1 ~ Tuple25,在实际开发中不能满足我们的需求,我们希望能有更大的元组,比如构建一个Tuple50。
> > > 请问有什么解决的方案? 谢谢
> > >
> >
>
>
> --
> **************************************
>  tivanli
> **************************************
>

Re: 回复: 关于拓展 Tuple元组的问题

Posted by Tianwang Li <li...@gmail.com>.
>
> 用 Row 啊,支持 Int.MAX 个元素,还能支持 null 值,不香么?
>
用Row 和 Tuple 性能上会有差别吗?

Jark Wu <im...@gmail.com> 于2020年6月19日周五 下午3:47写道:

> 用 Row 啊,支持 Int.MAX 个元素,还能支持 null 值,不香么?
>
>
> On Fri, 19 Jun 2020 at 15:42, Weixubin <18...@163.com> wrote:
>
> > 感谢你的回答,请问可否举一个参照例子?
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> > 在 2020-06-19 15:31:53,"wangweiguang@stevegame.cn" <
> > wangweiguang@stevegame.cn> 写道:
> > >
> > >   多个值组合在一起,当一个复合值使用!
> > >
> > >
> > >
> > >
> > >发件人: 魏旭斌
> > >发送时间: 2020-06-19 15:01
> > >收件人: user-zh
> > >主题: 关于拓展 Tuple元组的问题
> > >目前Flink 提供了Tuple1 ~ Tuple25,在实际开发中不能满足我们的需求,我们希望能有更大的元组,比如构建一个Tuple50。
> > 请问有什么解决的方案? 谢谢
> >
>


-- 
**************************************
 tivanli
**************************************

Re: Re: 回复: 关于拓展 Tuple元组的问题

Posted by 刘大龙 <ld...@zju.edu.cn>.
特别香!


> -----原始邮件-----
> 发件人: "Jark Wu" <im...@gmail.com>
> 发送时间: 2020-06-19 15:46:42 (星期五)
> 收件人: user-zh <us...@flink.apache.org>
> 抄送: 
> 主题: Re: 回复: 关于拓展 Tuple元组的问题
> 
> 用 Row 啊,支持 Int.MAX 个元素,还能支持 null 值,不香么?
> 
> 
> On Fri, 19 Jun 2020 at 15:42, Weixubin <18...@163.com> wrote:
> 
> > 感谢你的回答,请问可否举一个参照例子?
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> > 在 2020-06-19 15:31:53,"wangweiguang@stevegame.cn" <
> > wangweiguang@stevegame.cn> 写道:
> > >
> > >   多个值组合在一起,当一个复合值使用!
> > >
> > >
> > >
> > >
> > >发件人: 魏旭斌
> > >发送时间: 2020-06-19 15:01
> > >收件人: user-zh
> > >主题: 关于拓展 Tuple元组的问题
> > >目前Flink 提供了Tuple1 ~ Tuple25,在实际开发中不能满足我们的需求,我们希望能有更大的元组,比如构建一个Tuple50。
> > 请问有什么解决的方案? 谢谢
> >



Re: 回复: 关于拓展 Tuple元组的问题

Posted by Jark Wu <im...@gmail.com>.
用 Row 啊,支持 Int.MAX 个元素,还能支持 null 值,不香么?


On Fri, 19 Jun 2020 at 15:42, Weixubin <18...@163.com> wrote:

> 感谢你的回答,请问可否举一个参照例子?
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
> 在 2020-06-19 15:31:53,"wangweiguang@stevegame.cn" <
> wangweiguang@stevegame.cn> 写道:
> >
> >   多个值组合在一起,当一个复合值使用!
> >
> >
> >
> >
> >发件人: 魏旭斌
> >发送时间: 2020-06-19 15:01
> >收件人: user-zh
> >主题: 关于拓展 Tuple元组的问题
> >目前Flink 提供了Tuple1 ~ Tuple25,在实际开发中不能满足我们的需求,我们希望能有更大的元组,比如构建一个Tuple50。
> 请问有什么解决的方案? 谢谢
>

Re:回复: 关于拓展 Tuple元组的问题

Posted by Weixubin <18...@163.com>.
感谢你的回答,请问可否举一个参照例子?

















在 2020-06-19 15:31:53,"wangweiguang@stevegame.cn" <wa...@stevegame.cn> 写道:
>
>   多个值组合在一起,当一个复合值使用!
>
>
>
> 
>发件人: 魏旭斌
>发送时间: 2020-06-19 15:01
>收件人: user-zh
>主题: 关于拓展 Tuple元组的问题
>目前Flink 提供了Tuple1 ~ Tuple25,在实际开发中不能满足我们的需求,我们希望能有更大的元组,比如构建一个Tuple50。 请问有什么解决的方案? 谢谢