[FLINK-7415] [cassandra] Add example instructions for creating keyspace

This closes apache#4519.
deepfield · Aug 15, 2017 · 5f97ac9 · 5f97ac9
1 parent 9eeb5b2
commit 5f97ac9
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 5 deletions.
diff --git a/...andra/src/test/java/org/apache/flink/batch/connectors/cassandra/example/BatchExample.java b/...andra/src/test/java/org/apache/flink/batch/connectors/cassandra/example/BatchExample.java
@@ -34,8 +34,9 @@
 /**
  * This is an example showing the to use the Cassandra Input-/OutputFormats in the Batch API.
  *
- * <p>The example assumes that a table exists in a local cassandra database, according to the following query:
- * CREATE TABLE test.batches (number int, strings text, PRIMARY KEY(number, strings));
+ * <p>The example assumes that a table exists in a local cassandra database, according to the following queries:
+ * CREATE KEYSPACE IF NOT EXISTS test WITH replication = {'class': 'SimpleStrategy', 'replication_factor': ‘1’};
+ * CREATE TABLE IF NOT EXISTS test.batches (number int, strings text, PRIMARY KEY(number, strings));
  */
 public class BatchExample {
  private static final String INSERT_QUERY = "INSERT INTO test.batches (number, strings) VALUES (?,?);";

diff --git a/...ava/org/apache/flink/streaming/connectors/cassandra/example/CassandraPojoSinkExample.java b/...ava/org/apache/flink/streaming/connectors/cassandra/example/CassandraPojoSinkExample.java
@@ -32,7 +32,8 @@
  *
  * <p>Pojo's have to be annotated with datastax annotations to work with this sink.
  *
- * <p>The example assumes that a table exists in a local cassandra database, according to the following query:
+ * <p>The example assumes that a table exists in a local cassandra database, according to the following queries:
+ * CREATE KEYSPACE IF NOT EXISTS test WITH replication = {'class': 'SimpleStrategy', 'replication_factor': ‘1’};
  * CREATE TABLE IF NOT EXISTS test.message(body txt PRIMARY KEY)
  */
 public class CassandraPojoSinkExample {

diff --git a/...va/org/apache/flink/streaming/connectors/cassandra/example/CassandraTupleSinkExample.java b/...va/org/apache/flink/streaming/connectors/cassandra/example/CassandraTupleSinkExample.java
@@ -31,7 +31,8 @@
 /**
  * This is an example showing the to use the Tuple Cassandra Sink in the Streaming API.
  *
- * <p>The example assumes that a table exists in a local cassandra database, according to the following query:
+ * <p>The example assumes that a table exists in a local cassandra database, according to the following queries:
+ * CREATE KEYSPACE IF NOT EXISTS test WITH replication = {'class': 'SimpleStrategy', 'replication_factor': ‘1’};
  * CREATE TABLE IF NOT EXISTS test.writetuple(element1 text PRIMARY KEY, element2 int)
  */
 public class CassandraTupleSinkExample {

diff --git a/...che/flink/streaming/connectors/cassandra/example/CassandraTupleWriteAheadSinkExample.java b/...che/flink/streaming/connectors/cassandra/example/CassandraTupleWriteAheadSinkExample.java
@@ -36,7 +36,8 @@
 /**
  * This is an example showing the to use the Cassandra Sink (with write-ahead log) in the Streaming API.
  *
- * <p>The example assumes that a table exists in a local cassandra database, according to the following query:
+ * <p>The example assumes that a table exists in a local cassandra database, according to the following queries:
+ * CREATE KEYSPACE IF NOT EXISTS example WITH replication = {'class': 'SimpleStrategy', 'replication_factor': ‘1’};
  * CREATE TABLE example.values (id text, count int, PRIMARY KEY(id));
  *
  * <p>Important things to note are that checkpointing is enabled, a StateBackend is set and the enableWriteAheadLog() call