Yes, Chesnay is right. You can open and close the connection in
the open() and close() methods of your RichFlatMapFunction.
Kostas
> On Jul 7, 2016, at 11:03 AM, Chesnay Schepler wrote:
>
> Couldn't he do the same thing in his RichFlatMap?
>
> open the db connection in open(), close it in clo
Couldn't he do the same thing in his RichFlatMap?
open the db connection in open(), close it in close(), do stuff within
these calls.
On 07.07.2016 10:58, Kostas Kloudas wrote:
Hi Simon,
If your job reads or writes to a DB, I would suggest to use one of the already
existing Flink sources or
Hi Simon,
If your job reads or writes to a DB, I would suggest to use one of the already
existing Flink sources or sinks,
as this allows for efficient connection handling and managing.
If you want to write intermediate data to a DB from an operator, then I suppose
that you should implement
you
