Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[FLINK-7415][Cassandra Connector] Add comments for cassandra-connector test classes #4519

Closed
wants to merge 4 commits into from
Closed

[FLINK-7415][Cassandra Connector] Add comments for cassandra-connector test classes #4519

Changes from 1 commit
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
03e1e4a
add comments for BatchExample.java
yew1eb Aug 10, 2017
33ad86b
add comments for CassandraPojoSinkExample.java
yew1eb Aug 10, 2017
3b455b3
add comments for CassandraTupleSinkExample.java
yew1eb Aug 10, 2017
74f13d3
add comments for CassandraTupleWriteAheadSinkExample.java
yew1eb Aug 10, 2017
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
add comments for CassandraTupleSinkExample.java
  • Loading branch information
@yew1eb
yew1eb committed Aug 10, 2017
commit 3b455b32ba2b7d1a22b765b69490f6dd2d5d056b
3 changes: 2 additions & 1 deletion ...va/org/apache/flink/streaming/connectors/cassandra/example/CassandraTupleSinkExample.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down