弗林克代码

Question

我从cqlsh外壳

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

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

我想，如果不从弗林克代码存在，它创建密钥空间和表创建密钥空间和表卡桑德拉，内卡桑德拉创建表可有人请告诉我如何可以办到？

Answer 1

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

Answer 2

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

如果你想创建密钥空间/在C *表，如果它们尚未被弗林克创造了你可以这样做：

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));