Hi all, I'm looking for an example of Tranquility (Druid's lib) as a Flink sink.
I'm trying to follow the code in [1] but I feel it's incomplete or maybe outdated, it doesn't mention anything about other method (tranquilizer) that seems to be part of the BeamFactory interface in the current version. If anyone has any code or a working project to use as a reference that would be awesome for me and for the rest of us looking for a time-series database solution! Best regards, Matt [1] https://github.com/druid-io/tranquility/blob/master/docs/flink.md