Github user Bekreth commented on the issue:
https://github.com/apache/flink/pull/5538
Previously, I was trying to leverage the current annotation parsers.
It would be possible to pass in a keyspace more directly into
AnotationParser in the shaded Datastax component, but I'm against this as it
requires maintaining a version Datastax that differs from the open source
version.
It could be possible to just replace the entire annotation with reflections
instead of just editing 1 property, but that still requires some futzing in
reflections that I think would be best to avoid.
Another option could be to extend the necessary Datastax classes within the
CassandraPojoSink to facilitate the alterations necessary to pass in keyspace
dynamically. I'm thinking this is the most favorable option.
---
