Hi Frank ,
I think we have a similar case in my case I should be able to set the pojo
from the outside to analyze API-REST.
my strategy in my case and define my schema by using a JSON to convert JSON
data formats to Flink Row
so for example imagine your date is something like this : public stati
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
