add comments for BatchExample.java

apache · Aug 10, 2017 · 03e1e4a · 03e1e4a
1 parent 8c7b3d9
commit 03e1e4a
Showing 1 changed file with 3 additions and 2 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 (?,?);";