在Flink Code中在Cassandra中创建表

Question

我从 cqlsh shell

在卡桑德拉（Cassandra）创建了键空间和表格

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

我想创建键空间和表，如果它不存在Flink代码，请有人告诉我如何完成？

Answer 1

您可以查看测试用例org.apache.flink.streaming.connectors.cassandra.cassandraconnectoritcase.java，可能能够帮助您。

Answer 2

flink-cassandra连接器没有在卡桑德拉（Cassandra）创建键空间/表格的功能。您可以在此处查看连接器中的可用方法。

如果要在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));