用flink代码在cassandra中创建表

9rnv2umw 于 2021-06-25 发布在 Flink

关注(0)|答案(2)|浏览(322)

我在cassandra中从 cqlsh 壳

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

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

我想创建键空间和表，如果它不存在的flink代码，有人能告诉我怎么做吗？

cassandra apache-flink flink-streaming

来源：https://stackoverflow.com/questions/45992171/creating-table-in-cassandra-within-flink-code

2条答案

按热度按时间

gr8qqesn1#

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

赞(0）回复(0）举报 2021-06-25

ruoxqz4g2#

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

赞(0）回复(0）举报 2021-06-25