Hi,

So far I’ve been developing my flink pipelines using the datastream API. I
have a pipeline that calculates windowed statistics on a given pojo field.
Ideally I would like this field to be user configurable via a config file.
To do this I would need to extract pojo fields by name. The Table API seems
to have the facilities to do this. I gather datastreams can be converted to
Tables. Is it sensible to convert to tables in the middle of my datastream
pipeline to do this or is there a better way?

Thanks,

Frank

Reply via email to