Re: flink 1.11 udtf动态定义返回类型

Wed, 12 Aug 2020 19:28:23 -0700 

动态定义你指的是说字段的类型和数量都不是固定的吗？这个应该是不行的。你举的 1.10 例子也不是动态的呀

> 2020年8月12日 下午5:32，李强 <liqi...@skyon.com.cn> 写道：
> 
> flink 1.11 udtf可以像1.10那样自定义返回类型不我希望可以像flink 1.10这样：
> 
> @Override
> &nbsp; &nbsp; public TypeInformation<Row&gt; getResultType() {
> &nbsp; &nbsp; &nbsp; &nbsp; return new RowTypeInfo(Types.STRING, 
> Types.STRING);
> &nbsp; &nbsp; }
> 
> 
> 不希望像flink 1.11这样
> @FunctionHint(output = @DataTypeHint("ROW<name String,sex String&gt;"))
> 
> 
> udtf返回的字段个数和类型我们希望是可以动态的定义，就想flink 1.10那样

回复