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

Fri, 19 Jun 2020 01:31:18 -0700 

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




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

回复