关于拓展 Tuple元组的问题

classic Classic list List threaded Threaded
10 messages Options
Reply | Threaded
Open this post in threaded view
|

关于拓展 Tuple元组的问题

WeiXubin
目前Flink 提供了Tuple1 ~ Tuple25,在实际开发中不能满足我们的需求,我们希望能有更大的元组,比如构建一个Tuple50。 请问有什么解决的方案? 谢谢
Reply | Threaded
Open this post in threaded view
|

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

wangweiguang@stevegame.cn

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



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

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

WeiXubin
感谢你的回答,请问可否举一个参照例子?

















在 2020-06-19 15:31:53,"[hidden email]" <[hidden email]> 写道:

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

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

Jark
Administrator
用 Row 啊,支持 Int.MAX 个元素,还能支持 null 值,不香么?


On Fri, 19 Jun 2020 at 15:42, Weixubin <[hidden email]> wrote:

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

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

WeiXubin
感谢,这边做了一下简单测试,已解决~   真香




//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" <[hidden email]> 写道:

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

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

刘大龙
In reply to this post by Jark
特别香!


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


Reply | Threaded
Open this post in threaded view
|

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

Tianwang Li
In reply to this post by Jark
>
> 用 Row 啊,支持 Int.MAX 个元素,还能支持 null 值,不香么?
>
用Row 和 Tuple 性能上会有差别吗?

Jark Wu <[hidden email]> 于2020年6月19日周五 下午3:47写道:

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


--
**************************************
 tivanli
**************************************
Reply | Threaded
Open this post in threaded view
|

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

zhisheng
可以测试一下

Tianwang Li <[hidden email]> 于2020年6月29日周一 下午8:13写道:

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

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

Jingsong Li
> 用Row 和 Tuple 性能上会有差别吗?

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

Best,
Jingsong

On Tue, Jun 30, 2020 at 8:51 AM zhisheng <[hidden email]> wrote:

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


--
Best, Jingsong Lee
Reply | Threaded
Open this post in threaded view
|

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

LakeShen
哈哈,学习了一波

Jingsong Li <[hidden email]> 于2020年6月30日周二 上午9:59写道:

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