Hi,
what you can also do is use a RichMapFunction. Rich functions have
open()/close() methods that get called before the first element and the
last element, respectively.
See here
https://ci.apache.org/projects/flink/flink-docs-master/apis/common/index.html#specifying-transformation-functions
for
m
I am new to flink. I am wondering what the best practice is for looking up
additional values for entities embedded in an event.
For example, an event might have the engine model #. A metadata store has
the typical rpm characteristics of an engine model #; which can be used in
a subsequent processi
