在 Flink 代码中的 Cassandra 中创建表答案

【问题标题】：Creating table in Cassandra within Flink Code在 Flink 代码中的 Cassandra 中创建表
【发布时间】：2017-09-01 01:28:57
【问题描述】：

我在 Cassandra 中从 cqlsh shell 创建了键空间和表

 CREATE KEYSPACE data WITH replication= {'class':'SimpleStrategy', 'replication_factor':1;

 CREATE TABLE test.patient(id int, heart_rate int, PRIMARY KEY(id));

如果 Flink 代码中不存在 keyspace 和 Table，我想创建它，有人可以告诉我怎么做吗？

【问题讨论】：

标签： cassandra apache-flink flink-streaming

【解决方案1】：

你可以看看测试用例org.apache.flink.streaming.connectors.cassandra.CassandraConnectorITCase.java，或许能帮到你。

【讨论】：

【解决方案2】：

Flink-Cassandra 连接器没有在 Cassandra 中创建键空间/表的功能。您可以在连接器here 中查看可用的方法。

如果你想在 C* 中创建键空间/表（如果 Flink 尚未创建它们），你可以这样做：

CREATE KEYSPACE IF NOT EXISTS data WITH replication= {'class':'SimpleStrategy', 'replication_factor':1;
CREATE TABLE IF NOT EXISTS test.patient(id int, heart_rate int, PRIMARY KEY(id));

【讨论】：