flink 1.11 udtf动态定义返回类型

[李强]

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那样

[Zou Dan]

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

> 2020年8月12日 下午5:32，李强 <[hidden email]> 写道：
>
> 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那样