Re: StreamTableEnvironment.fromDataStream(dataStream)如何生成T类型的Schema?

Thu, 22 Sep 2022 20:20:30 -0700 

Hi @frank

你没有贴你定义的Event类代码，我觉得你的Event类定义有点问题
如果需要flink识别Event的内部字段，需要将Event定义成pojo类，例如将字段都定义成public，或者可以是private，但是需要增加setXXX和getXXX函数



On Thu, Sep 22, 2022 at 5:45 PM Frank <frank6...@qq.com.invalid> wrote:

> DataStreamSource<Event&gt; datastream = env.fromElements(
>                 new Event(0, "张三", 1L), new Event(0, "孙小美", 1L));
> StreamTableEnvironment tenv = StreamTableEnvironment.create(env);
> Table table = tenv.fromDataStream(datastream)
> table.printSchema();
> 为什么上面代码生成table的schema是下面这样而不是Event的字段（t, user, event, timestamp)？
> (
> &nbsp; `f0` RAW('utils.transfor.Event', '...')
> )
> 怎么改？

回复