in Cassandra innerhalb Flink-Code

Question

ich geschaffen habe Schlüsselraum und Tisch in Cassandra von cqlsh Shell

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

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

Ich mag Erstellen Tabelle Schlüsselraum und Tabelle erstellen, wenn es nicht von Flink Code nicht vorhanden ist, kann mir bitte jemand sagen, wie es kann getan werden?

Answer 1

Sie können den Testfall org.apache.flink.streaming.connectors.cassandra.CassandraConnectorITCase.java aussehen, kann Ihnen helfen.

Answer 2

Flink-Cassandra Connector verfügt nicht über die Funktion zum Erstellen von Schlüsselbereichen/Tabellen in Cassandra. Sie können verfügbare Methoden im Connector here überprüfen.

Wenn Sie Schlüsselraum/Tabellen in C * erstellt werden soll, wenn sie nicht bereits von Flink erstellt werden, können Sie tun:

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