flink的DataStream转成table时,表字段无法动态生成
flink的DataStream转成table时遇到一个问题:
从source采集的数据是DataStreamString,需要转成table，而且需要在转的时候指定字段(好像只能通过case class),
但是我的表字段是动态的，所以无法定义一个动态的case class，请问这种情况如何解决
其实你可以将所有字段都放到case class里面，在你source采集数据的时候没有数据的字段就默认为null就好了
flink的DataStream转成table时遇到一个问题:
从source采集的数据是DataStreamString,需要转成table，而且需要在转的时候指定字段(好像只能通过case class),
但是我的表字段是动态的，所以无法定义一个动态的case class，请问这种情况如何解决
其实你可以将所有字段都放到case class里面，在你source采集数据的时候没有数据的字段就默认为null就好了