You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Christopher Hughes (JIRA)" <ji...@apache.org> on 2018/02/14 14:05:02 UTC
[jira] [Created] (FLINK-8655) Add a default keyspace to
CassandraSink
Christopher Hughes created FLINK-8655:
-----------------------------------------
Summary: Add a default keyspace to CassandraSink
Key: FLINK-8655
URL: https://issues.apache.org/jira/browse/FLINK-8655
Project: Flink
Issue Type: Improvement
Affects Versions: 1.4.0
Reporter: Christopher Hughes
Fix For: 1.4.1
Currently, to use the CassandraPojoSink, it is necessary for a user to provide keyspace information on the desired POJOs using datastax annotations. This allows various POJOs to be written to multiple keyspaces while sinking messages, but prevent runtime flexibility.
For many developers, non-production environments may all share a single Cassandra instance differentiated by keyspace names. I propose adding a `defaultKeyspace(String keyspace)` to the ClusterBuilder. POJOs that lack a keyspace would be piped to the default.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)