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

2020-08-12 文章 Zou Dan
动态定义你指的是说字段的类型和数量都不是固定的吗?这个应该是不行的。你举的 1.10 例子也不是动态的呀

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




flink 1.11 udtf动态定义返回类型

2020-08-12 文章 李强
flink 1.11 udtf可以像1.10那样自定义返回类型不我希望可以像flink 1.10这样:

@Override
  public TypeInformation